apache-kafka
Filtering Kafka Records Python
I have a Kafka topic which consumes from different sources, I want to filter records based on some rules and deliver records to two different topics (one for valid records and one for invalid ones开发[详细]
2022-12-07 21:03 分类：问答Kafka KRaft - Topic Deletion
When attempting to delete a topic using the kafka-topics.sh script, I can see that the topics in the log.dir are marked for deletion, but not all partitions belonging to the topic have been marked.[详细]
2022-12-07 20:57 分类：问答Is it possible to set Delivery Time on kafka
I\'m new to kafka. For example I post a message to topic via producer. All subscriber in that topic will get notified.[详细]
2022-12-07 19:54 分类：问答Kafka producer failing with SIGSEGV panic when closing the producer connection
Application Functionality :Consumes messages from kafka queue and puts in buffered channel . From buffered channel, go function reads from that channel and do required message processing. if this mess[详细]
2022-12-07 19:11 分类：问答Why Program Control is not fetching consumer message from claim?
I am trying to implement a Kafka Consumer Group using shopify sarama client. I am kind of confused, how should aConsumerGroupHandler be used. Since, I don\'t know session and claim object. How can I u[详细]
2022-12-07 19:07 分类：问答Flink Fails on kafka NoClassDefFoundError
I have flink 1.14.4 job that have 2 kafka sources and 2 kafka sinks. After a time my job failed on the error[详细]
2022-12-07 18:49 分类：问答
![Interactive visualization of a graph in python [closed]](https://www.devze.com/res/2023/04-10/09/92d32fe8c0d22fb96bd6f6e8b7d1f457.gif)
加载中,请稍侯......