Kafka sender消息生產者

1.pom文件引入Kafka依賴（我用的版本是2.2.2.RELEASE）

<dependency>
            <groupId>org.springframework.kafka</groupId>
            <artifactId>spring-kafka</artifactId>
            <version>2.2.2.RELEASE</version>
        </dependency>

2.編寫Kafka sender工具類

@Component
public class KafkaSender {
    private static final Logger LOGGER = LoggerFactory.getLogger(KafkaSender.class);

    @Autowired
    private KafkaTemplate<String, Object> kafkaTemplate;

    // 發送消息方法
    public void send(String topic, String body) {
        kafkaTemplate.send(topic, body);
        LOGGER.info("發送消息完成,topic:{},內容為:{}", topic, body);
    }
}

3.在需要發送消息的地方，調用KafkaSender的send方法

測試一下：

@Test
    public void testSendKafka() {
        String message = "kafka test message";
        kafkaSender.send("topic", message);
    }