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开发
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.
I\'m new to kafka. For example I post a message to topic via producer. All subscriber in that topic will get notified.
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
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
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
加载中,请稍侯......