Kafka Streams получает идентификатор клиента в процессоре API

Question

Есть ли способ получить идентификатор клиента в процессоре?Я думаю, что это может быть возможно с помощью информации в контексте процессора?

Например, "my_app-e2e751f2-7c99-484d-9a5b-172de63bc6e1-StreamThread-1"

причинадля этого я хочу добавить новые метрики в существующее местоположение.

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

Answer 1

Есть ли способ получить идентификатор клиента в процессоре?

Вы можете получить доступ к application.id (который представляет идентификатор группы потребителей Kafka, используемый вашим приложением Kafka Streams), а также к идентификатору задачи потока через ProcessorContext:

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

Это то, что вам нужно?