Разметка Кафки в SpringBoot

Question

Я новичок в Кафке.Мне нужно написать простого производителя и потребителя для Kafka от Spring Boot. На самом деле я перехожу от микроавтобуса к Spring Boot.У меня проблема с разделением темы.В micronaut я использую @KafkaKey для ключа раздела, как показано ниже:

public void process(@KafkaKey MyKey kafkaKey, @Body MyRecord myRecord) 

Когда дело доходит до весны, я не знаю, как это сделать, потому что, как я вижу, класс KafkaTemplete имеет параметр раздела в качестве объекта Integer.

public ListenableFuture<SendResult<K, V>> send(String topic, Integer partition, K key, @Nullable V data) 

Так как мне выполнить первую строку в Spring Boot?

Answer 1

KafkaTemplate имеет разные способы отправки сообщений.Например:

1. Отправьте данные в предоставленную тему с указанным ключом и без раздела

send(java.lang.String topic, K key, V data)

Отправьте данные в указанную тему без ключа или раздела.

end(java.lang.String topic, V data)

Здесь вы можете выбрать наиболее подходящий способ: https://docs.spring.io/spring-kafka/api/org/springframework/kafka/core/KafkaTemplate.html