File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -26,7 +26,7 @@ errors as strings which allows you to decide how to handle it.
2626 local config , err = kafka_consumer .ConsumerConfig .create (
2727 {" localhost:9092" }, -- array of brokers
2828 " test_consumer" , -- consumer group
29- true , -- enable_auto_commit
29+ true , -- enable auto offset store
3030 {[" auto.offset.reset" ] = " earliest" } -- default configuration for topics
3131 )
3232 if err ~= nil then
@@ -94,7 +94,7 @@ errors as strings which allows you to decide how to handle it.
9494 local config , err = kafka_consumer .ConsumerConfig .create (
9595 {" localhost:9092" }, -- array of brokers
9696 " test_consumer" , -- consumer group
97- false , -- enable_auto_commit
97+ false , -- disable auto offset store
9898 {[" auto.offset.reset" ] = " earliest" } -- default configuration for topics
9999 )
100100 if err ~= nil then
You can’t perform that action at this time.
0 commit comments