我知道Kafka是如何判断消费者“死亡”的,以及Kafka协议中对心跳的一般支持(https://cwiki.apache.org/confluence/display/kafka/a+guide+to+the+kafka+protocol#aguidetothekafkaprotocol-心跳(请求)
在我的情况下,我特别有兴趣完成一些类似的生产者。
我正在修改一个现有的应用程序,该应用程序目前正在向另一个系统提交数据。正在更改该应用程序以将事件提交到kafka群集。除了其他类型的消息外,应用程序还提供心跳消息。我可以继续这样做,而是将这些心跳消息发送到一个主题(可能是一个日志压缩的主题)。
我想知道的是(a)Kafka是否明确跟踪制作人,以及(b)我是否可以访问这些信息,或者(c)我是否最好只是有一个专门用于此目的的主题?
暂无答案!
目前还没有任何答案,快来回答吧!