ack interval 128

1 year ago · 984b6c54cf
2 changed files with 2 additions and 0 deletions
--- a/.gitignore
+++ b/.gitignore
@ -87,3 +87,4 @@ other/java/hdfs/dependency-reduced-pom.xml

 # binary file
 weed/weed
+weed/mq/client/cmd/weed_pub/weed_pub
--- a/weed/mq/client/pub_client/lookup.go
+++ b/weed/mq/client/pub_client/lookup.go
@ -78,6 +78,7 @@ func (p *TopicPublisher) doConnect(partition *mq_pb.Partition, brokerAddress str
 					RangeStart: partition.RangeStart,
 					RangeStop:  partition.RangeStop,
 				},
+				AckInterval: 128,
 			},
 		},
 	}); err != nil {