File tree Expand file tree Collapse file tree 1 file changed +0
-4
lines changed Expand file tree Collapse file tree 1 file changed +0
-4
lines changed Original file line number Diff line number Diff line change @@ -225,7 +225,6 @@ r := kafka.NewReader(kafka.ReaderConfig{
225
225
Brokers : []string {" localhost:9092" ," localhost:9093" , " localhost:9094" },
226
226
Topic : " topic-A" ,
227
227
Partition : 0 ,
228
- MinBytes : 10e3 , // 10KB
229
228
MaxBytes : 10e6 , // 10MB
230
229
})
231
230
r.SetOffset (42 )
@@ -256,7 +255,6 @@ r := kafka.NewReader(kafka.ReaderConfig{
256
255
Brokers : []string {" localhost:9092" , " localhost:9093" , " localhost:9094" },
257
256
GroupID : " consumer-group-id" ,
258
257
Topic : " topic-A" ,
259
- MinBytes : 10e3 , // 10KB
260
258
MaxBytes : 10e6 , // 10MB
261
259
})
262
260
@@ -320,7 +318,6 @@ r := kafka.NewReader(kafka.ReaderConfig{
320
318
Brokers : []string {" localhost:9092" , " localhost:9093" , " localhost:9094" },
321
319
GroupID : " consumer-group-id" ,
322
320
Topic : " topic-A" ,
323
- MinBytes : 10e3 , // 10KB
324
321
MaxBytes : 10e6 , // 10MB
325
322
CommitInterval : time.Second , // flushes commits to Kafka every second
326
323
})
@@ -719,7 +716,6 @@ r := kafka.NewReader(kafka.ReaderConfig{
719
716
Brokers : []string {" localhost:9092" , " localhost:9093" , " localhost:9094" },
720
717
Topic : " my-topic1" ,
721
718
Partition : 0 ,
722
- MinBytes : batchSize,
723
719
MaxBytes : batchSize,
724
720
})
725
721
You can’t perform that action at this time.
0 commit comments