如何监控kafka客户端使用的TRANSACTIONAL_ID ?

Question

这可能更多的是关于生产者。如果allow.everyone.if.no.acl，则需要为客户端使用的每个资源定义适当的ACL。Found =false即将被设置，这应该是期望的状态，那么，如何在没有开发人员帮助的情况下监控它以找出实际需要的东西呢?

Answer 1

我想目前没有比这个问题更好的答案了:

读取Kafka 0.11.0.1中_transaction_state主题的数据

为了稍微改进一下，让我们将链接发布到相关类，即:

https://github.com/a0x8o/kafka/blob/master/core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala

如果我比较我提出的kafka-console-consumer命令的结果与应用于它的TransactionLogMessageFormatter，到readTxnRecordValue函数中呈现的实现，我看到我错过了一些TransactionMetadata，我的记录看起来像这样:

txn_id::TransactionMetadata(transactionalId=txn_id, producerId=440243, producerEpoch=14094, txnTimeoutMs=600000, state=Empty, pendingState=None, topicPartitions=Set()， txnStartTimestamp=-1, txnLastUpdateTimestamp=1613483758593)

所以，没有lastProducerId和lastProducerEpoch，可能是由于我正在运行的旧版本(kafka_type .13-2.6.0)?