Kafka Streams在处理器API中获取客户端Id

Question

有办法在处理器中获取客户端id吗？我的想法是，它是否可以在处理器上下文中使用信息构建？

例如，"my_app-e2e751f2-7c99-484d-9a5b-172de63bc6e1-StreamThread-1">

为此，我想在现有位置添加新的度量。

kafka.streams->my_app-e2e751f2-7c99-484d-9a5b-172de63bc6e1-流线程1->*

Answer 1

有办法在处理器中获取客户端id吗？

您可以通过ProcessorContext:访问application.id(表示Kafka Streams应用程序使用的Kafka使用者组ID)以及流任务ID

ProcessorContext#applicationId()
ProcessorContext#taskId()

有关更多信息，请参阅Apache Kafka 2.1文档：

• https://kafka.apache.org/21/javadoc/org/apache/kafka/streams/processor/ProcessorContext.html
• https://kafka.apache.org/21/documentation/streams/developer-guide/config-streams.html#application-id

这就是你需要的吗？