我是Kafka的新人。我需要写一个简单的生产者和消费者Kafka的 Spring 开机。实际上我从micronaut移动到 Spring 开机。我对主题的划分有问题。在micronaut中，我使用@kafkakey作为分区键，如下所示：
public void process(@KafkaKey MyKey kafkaKey, @Body MyRecord myRecord)说到spring，我不知道该怎么做，因为我看到kafkateComplete类的partition参数是整数对象。
public ListenableFuture<SendResult<K, V>> send(String topic, Integer partition, K key, @Nullable V data)那么，如何执行springboot中的第一行呢？
1条答案
按热度按时间643ylb081#
kafkatemplate有不同的发送消息的方法。例如：
使用提供的密钥将数据发送到提供的主题，而不使用分区
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