kafka-python

kafka-python copied to clipboard

Hi. I noticed the [OffsetDelete API](https://kafka.apache.org/24/protocol.html#The_Messages_OffsetDelete) is missing support in this library. Why is that so? If it's okay, I can open a pull request adding it

RyanSept

my environment is a cluster with four brokers in two pods, when i shutdown 2 of brokers, i supposed to see kafka'client connecti other active brokers,but sometime failed .i see...

ohye3166

benbariteau

Currently kafka header value is byte. When we are consuming it from the kafka it is in byte. so we again convert it to string. Is there any possibility of...

tara-9

NoBrokersAvailable

2

While trying to run the producer I keep on getting this issue, I have tried adding api_version to the code but its not working. Can anybody help Traceback (most recent...

aa1633350

Need a way to be able to specify a credential cache file as part of authentication when multiple files are present within the cache directory. I found this can be...

zenoran

and the configuration of ConsumerInterceptor and ProducerInterceptor was not found

junzisheng

issue: Iterator results in "Heartbeat poll expired, leaving group" if topic is idle for several hours, but can see message "Received successful heartbeat response" seconds ago. Iterator results in heartbeat...

cainbit

Integration with Confluent?

1

Hello, in my company we developed a sort of wrapper around this library in order to integrate the Confluent schema registry and perform the Avro serialization. We are now considering...

jacopofar

Would you consider support for MSK & IAM integration ?

5

Hello AWS announced support for a new SASL mechanism called AWS_MSK_IAM which enables to handle both authentication and authorisation with AWS IAM. Is there a chance to add support for...

andormarkus