【发布时间】:2021-03-17 05:01:17
【问题描述】:
这可能更多地是关于生产者。如果将要设置 allow.everyone.if.no.acl.found=false ,则需要为客户端使用的每个资源定义适当的 ACL,无论如何这应该是所需的状态,那么,如何监视它以在没有开发人员帮助的情况下找出实际需要什么?
【问题讨论】:
标签: security apache-kafka monitoring
这可能更多地是关于生产者。如果将要设置 allow.everyone.if.no.acl.found=false ,则需要为客户端使用的每个资源定义适当的 ACL,无论如何这应该是所需的状态,那么,如何监视它以在没有开发人员帮助的情况下找出实际需要什么?
【问题讨论】:
标签: security apache-kafka monitoring
我想目前没有比这个问题更好的答案了:
Reading data from _transaction_state topic in Kafka 0.11.0.1
为了改进一点,让我们发布相关课程的链接,即:
如果我将提议的 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_2.13-2.6.0)?
【讨论】: