why the auto commit is not work?

[yingzi20]

Questions?

• Check the Troubleshooting / FAQ ?
• Search the issues ?

Bug Report

Environment

• Node version: 10
• Kafka-node version: latest
• Kafka version: latest

For specific cases also provide

• Number of Brokers: 1
• Number partitions for topic: 50

Include Sample Code to reproduce behavior

new kafka.Consumer(client, topics, {
        // Auto commit config
        autoCommit: true,
        autoCommitIntervalMs: 5000,
        // The max wait time is the maximum amount of time in milliseconds to block waiting if insufficient data is available at the time the request is issued, default 100ms
        fetchMaxWaitMs: 100,
        // This is the minimum number of bytes of messages that must be available to give a response, default 1 byte
        fetchMinBytes: 1,
        // The maximum bytes to include in the message set for this partition. This helps bound the size of the response.
        fetchMaxBytes: 1024 * 1024 * 1024,
        // If set true, consumer will fetch message from the given offset in the payloads
        fromOffset: false,
        // If set to 'buffer', values will be returned as raw buffer objects.
        encoding: 'utf8',
        keyEncoding: 'utf8'
      })

why the consumer data is % coverage, 974174 lag?

[yingzi20]

I have another question the why the consumer type is ZK? how to change it to KF?