confluent-kafka-python
confluent-kafka-python copied to clipboard
confluentinc
Confluent's Kafka Python Client
Description =========== Getting the above error when importing the from confluent_kafka.admin import (AdminClient, NewTopic) How to reproduce ================ 1. Spin up a Amazon Linux EC2 environment 2. Check Python3 Version...
Description =========== Getting Error when installing confluent-kafka from source for GSSAPI support #5 9.889 2673 | error = rd_kafka_sasl_set_credentials(self->rk, username, password); #5 9.889 | ^ #5 9.889 error: command 'gcc'...
Description =========== When trying to connect to MSK AWS getting below error **%3|1686828089.194|FAIL|rdkafka#consumer-1| [thrd:sasl_ssl://*kafka.us-east-2]: sasl_ssl://*.amazonaws.com:9196/bootstrap: SASL authentication error: SaslAuthenticateRequest failed: Local: Broker handle destroyed (after 0ms in state DOWN)** How...
I am simply trying to read messages from Kafka partition in a topic. Here is my code: partition = 1 par=1 #msg = consumer.poll(1.0) partition = TopicPartition(topic, partition) consumer.assign([partition]) offset_tuple=consumer.get_watermark_offsets(partition)...
Description =========== Is there way to not receive any delivery reports from the broker or atleast not queue these delivery reports even if we receive them.I've seen a configuration `delivery.report.only.error`...
Description =========== waiting for futures returned by AdminClient.delete_consumer_groups() fails assertions. How to reproduce ================ ```py def reset(conf): admin_client = AdminClient(conf) futures: dict[str, _] = admin_client.delete_consumer_groups([CONSUMER_GROUP]) for _consumer, future in futures.items():...
Description =========== 'py_client_tt2' cannot consume data from 'mytopic' (it can be confirmed that there is data in 'mytopic'). Below are the logs, and the confluent-kafka-python used is 2.2.0, which uses...
Description =========== After a few hours(unpredictable) of running the program, it's bound to keep throwing BufferError, cannot recover itself unless we restart the app. QPS of msgs send is about...
Description =========== Hi , General guidance / question we couldn't find good source online: we have a consumer who is working on 2 topics, internal_events and external_events. We want to...
Description =========== Admin client from the library doesn't support specification of a logger. It generates the error: ` TypeError: __init__() got an unexpected keyword argument 'logger ` However, the producer...
