Как получить partitionId и TopicName в приложении KafkaStream

Question

Как получить топи c имя и идентификатор раздела из KafkaStream. Для любого другого потребителя Kafka мы можем получить topi c name и partitionId примерно так:

    ConsumerRecords<String, String> records = consumer.poll(100);
for (ConsumerRecord<String, String> record : records) {System.out.printf("consumed: key = %s, value = %s, partition id= %s, offset = %s%n",record.key(), record.value(), record.partition(), record.offset());}

Не знаю, как получить ссылку на запись в KafkaStreams.

Answer 1

Вы можете получить метаданные входной записи через ProcessorContext, который предоставляется в API процессора. Вы можете встроить Processor API в DSL с помощью transform() и аналогичных методов.

Подробнее см. В документации: https://docs.confluent.io/current/streams/developer-guide/processor-api.html#accessing -processor-context