confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== I use consume function to get messages in batches，and the message is lost after calling the seek function. How to reproduce ================ The following code reproduces the problem...
Description =========== Currently the python client fails to handle multiple schema registry urls. In order to more closely align the python client with its Java counterpart it should be updated...
This is not a bug, just a question. I'm not clear on what I should do if I encounter a `message.error()`. My goal is to process 100% of the input...
Hello, I see that the new version of librdkafka is out and I would like to know when will it compatible with this wrapper. I am interested in delete consumer...
Description =========== I'm working with a PostgreSQL plpython3u function for messages production, these messages are sent without key. In my case I'm must have this function able to send only...
We are interested in using kafka streaming. Is it on the road map for confluent kafka python library?
Description =========== I am trying this package and have noticed that it leaks in some special cases. I try to produce a too large message and when I catch the...
Description =========== I am doing some tests, first i sent 5 messages with payload of 1MB, then 50, 500 with same payload, it works well. But when i send 5k...
Fixes #926 Otherwise the python and java implementations are mutually incompatible. Is there anything else that needs to be done about this w.r.t. backwards compatibility? This version will be incompatible...
Description =========== While reading data from a consumer and writing to a sink I get the following error: `Assertion failed: rd_slice_abs_offset(new_slice) end (rdbuf.c: rd_slice_narrow_copy: 1027)` No additional information is provided....
