我正在用Kafka流开发一个poc。现在我需要在流使用者中获得偏移量值，并使用它生成一个唯一的键 (topic-offset)->hash 对于每条消息。原因是：生产者是syslog，只有少数人有id。我无法在使用者中生成uuid，因为在重新处理的情况下，我需要重新生成相同的密钥。
我的问题是 org.apache.kafka.streams.processor.ProcessorContext 类暴露 .offset() 方法返回值，但我使用kstream而不是处理器，并且找不到返回相同内容的方法。
有人知道如何从kstream中提取每一行的消费者价值吗？提前谢谢
1条答案
按热度按时间unhi4e5o1#
您可以通过
process(...),transform(...)，和transformValues(...).它允许您访问与普通处理器api类似的当前记录偏移量。在你的情况下，似乎你想使用
KStream#transform(...).