Skip to content

AvroConsumer on_commit callback #546

Closed
@gaisanshi

Description

@gaisanshi

Description

I know Consumer constructor has on_commit callback parameter. I am looking for the same callback for AvroConsumer. But I didn't find it. Should I call c function rd_kafka_conf_set_offset_commit_cb?

How to reproduce

N/A

Checklist

Please provide the following information:

  • confluent-kafka-python and librdkafka version (confluent_kafka.version() and confluent_kafka.libversion()): 0.11.6,
  • Apache Kafka broker version:
  • Client configuration: {...}
  • Operating system:
  • Provide client logs (with 'debug': '..' as necessary)
  • Provide broker log excerpts
  • Critical issue

Metadata

Metadata

Assignees

Labels

enhancementRequesting a feature change

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions