- [Breaking] Deprecate and remove
#each_batchdue to data consistency concerns. - [Enhancement] Bump librdkafka to 2.8.0
- [Fix] Restore
Rdkafka::Bindings.rd_kafka_global_initas it was not the source of the original issue.
#each_batch due to data consistency concerns.Rdkafka::Bindings.rd_kafka_global_init as it was not the source of the original issue.