Kafka sender消息生产者

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

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

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