10分钟带你逆袭Kafka！(13) _Kafka

maven 配置：
    <dependency>      <groupId>org.apache.kafka</groupId>      <artifactId>kafka-clients</artifactId>      <version>2.1.1</version>    </dependency>
添加配置文件，在 Application.properties 中加入如下配置信息：

Kafka 连接地址：
spring.kafka.bootstrap-servers = 192.168.51.128:9092,10.231.128.96:9093,192.168.51.128:9094
生产者：
spring.kafka.producer.acks = 0spring.kafka.producer.key-serializer = org.apache.kafka.common.serialization.StringSerializerspring.kafka.producer.value-serializer = org.apache.kafka.common.serialization.StringSerializerspring.kafka.producer.retries = 3spring.kafka.producer.batch-size = 4096spring.kafka.producer.buffer-memory = 33554432spring.kafka.producer.compression-type = gzip
消费者：
spring.kafka.consumer.group-id = mygroupspring.kafka.consumer.auto-commit-interval = 5000spring.kafka.consumer.heartbeat-interval = 3000spring.kafka.consumer.key-deserializer = org.apache.kafka.common.serialization.StringDeserializerspring.kafka.consumer.value-deserializer = org.apache.kafka.common.serialization.StringDeserializerspring.kafka.consumer.auto-offset-reset = earliestspring.kafka.consumer.enable-auto-commit = true# listenner, 标识消费者监听的个数spring.kafka.listener.concurrency = 8# topic的名字kafka.topic1 = topic1
生产者：
import lombok.extern.slf4j.Slf4j;import org.springframework.beans.factory.annotation.Value;import org.springframework.kafka.core.KafkaTemplate;@Service@Slf4jpublic class MyKafkaProducerServiceImpl implements MyKafkaProducerService {        @Resource    private KafkaTemplate<String, String> kafkaTemplate;        // 读取配置文件    @Value("${kafka.topic1}")    private String topic;    @Override    public void sendKafka() {      kafkaTemplate.send(topic, "hell world");    }}
消费者：
@Component@Slf4jpublic class MyKafkaConsumer {  @KafkaListener(topics = "${kafka.topic1}")    public void listen(ConsumerRecord<?, ?> record) {        Optional<?> kafkaMessage = Optional.ofNullable(record.value());        if (kafkaMessage.isPresent()) {            log.info("----------------- record =" + record);            log.info("------------------ message =" + kafkaMessage.get());}
作者：凌晶

简介：生活中的段子手，目前就职于一家地产公司做 Devops 相关工作，曾在大型互联网公司做高级运维工程师，熟悉 linux 运维，Python 运维开发，Java 开发，Devops 常用开发组件等，个人公众号：stromling，欢迎来撩我哦！

10分钟带你逆袭Kafka！(13)

推荐阅读

【杜润旺】宏远新招数！杜润旺沦为“备胎”？其实他已经是人生赢家

北京寄东西回重庆，快递哪家划算

|英囤积者家中堆满6万件物品，大部分为未拆快递，自己被迫住旅馆

#综合#法国教育部长：我们流失了5%至8%的学生

王者荣耀|王者荣耀：已经出了5款周年限定，原始高清海报一览，这个共同点最良心

柠檬蜂蜜茶|夏天首饰别乱戴！建议这3种款式，洋气有面子，?女人过了40岁

立春节气推荐三款养生汤

脱口秀演员卡姆容留他人吸毒被判有期徒刑8个月

鲤鱼|弄明白这几句话，野钓找鱼窝，简直易如反掌

穿搭|清新可人的比基尼泳衣美女，轻松拥有优美曲线，尽显甜美洋气感！

井柏然|井柏然宋威龙露营：看成了官宣恋情

中国首枚芯片邮票面世

【钱甜圈】可以影响世界的美联储为什么那么牛

该怎样来修剪才比较好？枣树修剪

八年级数学一次函数的应用一次函数的应用

骁龙898|安卓阵营跑分王预定！骁龙8 Gen1跑分破百万稳了

几许狼烟|留下巨大弹坑，亚美尼亚动用最强导弹袭击阿塞拜疆第二大城市：民居楼被摧毁

国民乐见晚上俺翻来覆去睡不着，开心笑话：昨天男友突然被公司派去出差

华纳|华纳发布《信条》港台版海报

人社部|人社部：行业协会商会证书不能使用“中国”、“中华”等字样