Для чего используется аннотация @KafkaKey?

Question

Я новичок в Kafka и micronaut, и я не понимаю, как использовать @KafkaKey.В интернете я обнаружил:

Ключ Kafka можно указать, указав параметр, помеченный @KafkaKey.Если такой параметр не указан, запись отправляется с нулевым ключом.

Так что же это значит?Как это повлияет на меня, если я им не пользуюсь?

Answer 1

Наиболее важным эффектом ключей сообщений Kafka является разбиение.Например, если выбранный ключ был идентификатором пользователя, тогда все данные для данного пользователя будут отправлены в один и тот же раздел.Если вы не укажете ключ сообщений, Kafka будет использовать стратегию циклического перебора для распространения сообщений.

Answer 2

Кафка сохраняет порядок внутри перегородок.Поскольку вы указываете ключ для определенного типа сообщения, тип сообщения привязывается к определенному разделу, связанному с этим ключом.Так как порядок сообщений сохраняется в разделе, вы можете сохранить порядок сообщений, указав ключ.Это особенно полезно, если вы работаете с конечными автоматами.