confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== _SchemaCache should not be used in SchemaRegistryClient , since the "delete_subject" method is provided and no update the cache.
Description =========== Hello, I am trying to get my integrate confluent_kafka in my Django webapp and it gives my quite a hard time. I have several question, hopefully you could...
Description =========== I'm experiencing a flaky behavior where upon `AdminClient(...).create_topics([NewTopic(topic, ...)])` and I immediately `AdminClient.list_topics(timeout=-1)`, I don't see the topic. I suspect one of the following is happening: - `create_topics`...
Description =========== I had to write a class like the `AggregateSerializer` below recently. It seems like something that would naturally be in the library given producers can produce to multiple...
` c = Consumer({ 'bootstrap.servers': servers, 'group.id': groupid, 'auto.offset.reset': offsettype, # 'auto.offset.reset': 'latest', }) c.subscribe([topic])` When I created the consumer, I thought it would be obvious if there was no...
Description =========== This issue occurs when a schema is registered with schema references. Several of the schema registry APIs return schemas that do not correctly construct their list of references....
Description =========== In the Confluent blog post [Putting Several Event Types in the Same Topic – Revisited](https://www.confluent.io/blog/multiple-event-types-in-the-same-kafka-topic/), the author describes how to use [use Avro unions with schema references](https://www.confluent.io/blog/multiple-event-types-in-the-same-kafka-topic/#avro-unions-with-schema-references). The...
According to the doc, poll() only returns None in the timeout situation. I notice that poll() also returns None if the value of the message is None. Is this an...
I have spark job which reads data from S3 and publish that to kafka using 'confluent-kafka-python'. Below is the code which I am using, I am just trying to test...
Description =========== When I disable auto commit with 'enable.auto.commit': False , and call poll(), the consumer doesn't commit and it's working fine, like it's said in the docs. But on...
