Где взять correlationId для кафки?

Question

[gsaw]

Привет,

надо реализовать в приложении spring на кафке command/response. Для этого умные дяди говорят надо устанавливать correlationId в хидере. Я не пойму, где его брать. Можно просто секунды (или миллисекунды, что бы совсем однозначно было) с начала "времен" использовать? Или kafka сама как то это может и делает?

Спасибо

Comments

[Василий Банников]

Можно просто новый гуид сгенерить

[gsaw]

Василий Банников, я искал в гугле, вроде часто его как integer определяют. Но я нашел в спринге CorrelationKey Класс. Он вообще byte[], так что наверное да, можно случайный UUID использовать. В спринге есть оказывается такая штука как ReplyingKafkaTemplate. Которая сама может генерировать corelationId, но это не точно. Возможно надо самому генератор задавать.