confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== We have hit the same issue as described in https://github.com/confluentinc/confluent-kafka-dotnet/issues/701. First publish to a topics takes ~1s. Workaround with prefetching metadata works in golang but doesn't work in...
protobuf class [MessageFactory](https://github.com/protocolbuffers/protobuf/blob/main/python/google/protobuf/message_factory.py#L179) is deprecated, and it is generating deprecation warnings when called. Instead of calling `MessageFactory().GetPrototype(descriptor)` (that will only generate a deprecation warning and call `GetMessageClass(descriptor)`), we should call...
Description =========== Issue with termination of kafka consumer. When consumer has being cunsuming messages for over a number of hours, it will fail to fully terminate and hang. consumer.close() is...
Hello, this pull requests adds a method called `io_event_enable` to the `Consumer`. It simply wraps `rd_kafka_queue_io_event_enable` from librdkafka. My goal is to make integration with async frameworks easier. Using it...
The SchemaRegistryClient `delete_version()` function does not have `?permanent=true` functionality mentioned in Schema Registry API reference - https://docs.confluent.io/platform/current/schema-registry/develop/api.html#delete--subjects-(string-%20subject)-versions-(versionId-%20version) https://github.com/confluentinc/confluent-kafka-python/blob/370d62e2029d80f12fdf04dca9afbbd664962625/src/confluent_kafka/schema_registry/schema_registry_client.py#L563-L585 Added flag support similar to `delete_subject()` implementation and taking into the account...
If you call describe_topics on a flaky connection, sometimes the admin client reply has the host set to a null pointer. When this occurs, instead of segfaulting, report the host...
Exposing `topic_new` function in python to be able to set per-topic configuration Fixes #1671
refactor with fstring to format string to make code more Pythonic.
Description =========== Hello！ I encountered difficulties using the "AdminClient. list_offsets" method, I want to obtain the timestamp corresponding to the offset, However, the timestamp obtained using the "result. timestamp" method...
