【问题标题】:How to monitor TRANSACTIONAL_ID in use by kafka clients?如何监控 kafka 客户端使用的 TRANSACTIONAL_ID?
【发布时间】:2021-03-17 05:01:17
【问题描述】:

这可能更多地是关于生产者。如果将要设置 allow.everyone.if.no.acl.found=false ,则需要为客户端使用的每个资源定义适当的 ACL,无论如何这应该是所需的状态,那么,如何监视它以在没有开发人员帮助的情况下找出实际需要什么?

【问题讨论】:

    标签: security apache-kafka monitoring


    【解决方案1】:

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

    Reading data from _transaction_state topic in Kafka 0.11.0.1

    为了改进一点,让我们发布相关课程的链接,即:

    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_2.13-2.6.0)?

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2023-03-14
      • 2011-04-04
      • 2013-12-22
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多