kafkaTemplate.send批量写入数据
时间: 2023-08-09 19:11:52 浏览: 274
您可以使用`kafkaTemplate.send`方法来批量写入数据到Kafka中。下面是一个示例代码:
```java
import org.apache.kafka.clients.producer.ProducerRecord;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;
import java.util.List;
@Component
public class KafkaProducer {
@Autowired
private KafkaTemplate<String, String> kafkaTemplate;
public void sendBatch(List<String> messages, String topic) {
for (String message : messages) {
kafkaTemplate.send(new ProducerRecord<>(topic, message));
}
kafkaTemplate.flush();
}
}
```
在上述示例中,`kafkaTemplate.send`方法被用于发送一条消息到指定的Kafka主题。您可以在`sendBatch`方法中循环调用`kafkaTemplate.send`来批量写入多条消息。最后,调用`kafkaTemplate.flush`方法来确保所有消息都被发送到Kafka中。
请注意,上述示例中使用的是`KafkaTemplate<String, String>`,其中第一个类型参数表示键的类型,第二个类型参数表示值的类型。您可以根据实际情况进行调整。
希望对您有所帮助!如果有任何疑问,请随时提问。
阅读全文