Closed
Description
Hello,
I'm using KafkaConsumer with api_version=(0, 8, 1)
and enable_auto_commit=True
.
I need to use api_version 0.8.1 since the consumer I'm migrating from uses OffsetCommitRequest
version 0 and so stores offsets on zookeeper.
The offsets are not periodically committed as expected. From what I can understand this is due to early exit in coordinator.ConsumerCoordinator.poll()
Metadata
Metadata
Assignees
Labels
No labels