Kafka sender消息生产者

Posted 2022-09-27 koudaiyoutang

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);