Questions about confluent-kafka-python
Read more about confluent-kafka-python
python (12.9k questions)
javascript (9.2k questions)
reactjs (4.7k questions)
java (4.2k questions)
java (4.2k questions)
c# (3.5k questions)
c# (3.5k questions)
html (3.3k questions)
Read Data from Kafka Broker at Specific Time Intervals (Python)
I have a system where a machine is reading data and continuously appends a .txt file. This dataset is read into a Kafka broker via Kafka Connect and would then be pre-processed with some Python code. ...
Aaron Gonzalez
Votes: 0
Answers: 1
AvroSerializer: schema for orderbook snapshots
I have a Kafka cluster running and I want to store L2-orderbook snapshots into a topic that have a dictionary of {key:value} pairs where the keys are of type float as the following example:
{
'exc...
CarloP
Votes: 0
Answers: 2
Confluent-Kafka python delete_topic getting recreated
When I'm trying to delete a Kafka topic using Confluent-Kafka AdminClient Delete_topic, The topic is getting deleted for the moment but is getting recreated after few seconds.
I tried Producer.flush()...
Shubhendra Tomar
Votes: 0
Answers: 0
confluent-kafka Timed out OffsetCommitRequest
im using confluent-kafka 1.8.2.
Faced a problem, after N messages the consumer crashes with an error.
GroupCoordinator/5: Timed out OffsetCommitRequest in flight (after 60165ms, timeout #0)
Please hel...
Дима Январёв
Votes: 0
Answers: 0