spring boot集成kafka
前言实现功能:在SpringBoot快速实现集成Kafka的操作。有多快?只需要3分钟!!创建Kafka项目IDEA选择FILE-New-Project-Spring Initaliz,然后进行下图设置,初始化项目配置spring:kafka:bootstrap-servers: 192.168.0.119:9092consumer:group...
·
前言
实现功能:
在SpringBoot快速实现集成Kafka的操作。有多快?只需要3分钟!!
创建Kafka项目
IDEA选择FILE-New-Project-Spring Initaliz,然后进行下图设置,初始化项目
配置
spring:
kafka:
bootstrap-servers: 192.168.0.119:9092
consumer:
group-id: test-consumer-group-1
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
producer:
bootstrap-servers: 192.168.0.119:9092
生产者
@Component
public class KafkaP {
@Autowired
KafkaTemplate kafkaTemplate;
public void sendMessage(Object message) {
kafkaTemplate.send("test", message);
}
}
消费者
@Component
public class KafkaC {
@KafkaListener(topics = "test")
public void kafka(ConsumerRecord<?, ?> record) {
System.out.println("收到来自test的消息:" + record.value());
}
}
生产者测试
@RunWith(SpringRunner.class)
@SpringBootTest
public class DemoApplicationTests {
@Autowired
KafkaP kafkaP;
@Test
public void contextLoads() {
kafkaP.sendMessage("邪剑仙");
}
}
项目入口文件
@SpringBootApplication
public class DemoApplication {
public static void main(String[] args) {
SpringApplication.run(DemoApplication.class, args);
}
}
进行测试
首先,启动DemoApplication,初始化消费者环境。
然后,DemoApplicationTests运行contextLoads方法,发送消息。
项目截图
更多推荐
已为社区贡献1条内容
所有评论(0)