spring boot 集成kafka
2019-05-06 15:31
162 查看
版权声明:诸葛子房 https://blog.csdn.net/weixin_43291055/article/details/92616895
spring boot 集成kafka
1、先解决依赖
springboot相关的依赖我们就不提了,和kafka相关的只依赖一个spring-kafka集成包
<dependency> <groupId>org.springframework.kafka</groupId> <artifactId>spring-kafka</artifactId> <version>2.2.0.RELEASE</version> </dependency>
这里我们先把配置文件展示一下
#============== kafka producer===================
spring.kafka.producer.bootstrap-servers=localhost:9092
spring.kafka.producer.retries=1
spring.kafka.producer.batch-size=16384
spring.kafka.producer.buffer-memory=33554432
spring.kafka.producer.properties.max.requst.size=2097152
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
#=============== consumer =======================
spring.kafka.consumer.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=0
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.enable-auto-commit=true
spring.kafka.consumer.auto-commit-interval=100
#=======set comsumer max fetch.byte 2*1024*1024=============
spring.kafka.consumer.properties.max.partition.fetch.bytes=2097152
2、Kafka producer
@Order(value = 1)
@Component
@Slf4j
public class Producer implements CommandLineRunner {
@Autowired
private KafkaTemplate<String, Object> kafkaTemplate;
@Override
public void run(String... strings) throws Exception {
while (true) {
log.info("kafka的消息");
kafkaTemplate.send("test", "zhugezifang");
log.info("发送kafka成功.");
Thread.sleep(5000);
}
}
}
3、kafka consumer
@Component
@Slf4j
public class Consumer {
@KafkaListener(topics = {"test"})
public void listen(ConsumerRecord<?, ?> record) {
log.info("topic:{}, offset:{}, value:{}", record.topic(), record.offset(), record.value());
}
}
posted @ 2019-05-06 15:31 诸葛子房 阅读(...) 评论(...) 编辑 收藏
相关文章推荐
- spring boot 集成kafka (多线程,消费者使用kafka的原生api实现,因为@KakfkaListener修改groupId无效)
- Spring Boot集成kafka笔记
- springboot和kafka集成
- Apache Kafka 入门 - Spring Boot 集成 Kafka
- springboot 1.5.2 集成kafka 简单例子
- spring boot 集成kafka
- springboot kafka集成
- springboot 1.5.3集成kafka
- spring-boot集成kafka
- 教你无脑在springBoot项目中集成ELK+Kafka
- spring boot与kafka集成的简单实例
- spring boot 集成spark-streaming-kafka
- springboot 集成kafka 实现多个customer不同group
- Kafka 安装-配置-监控 与集成springboot
- springboot 1.5.2 集成kafka 简单例子
- spring boot kafka集成
- Spring Boot集成kafka笔记
- springboot kafka集成
- spring boot 与kafka集成
- springboot kafka集成(实现producer和consumer)