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)

推荐阅读

『新能源』占全年47.4%！2019年全国四季度新增风电装机数据及新能源消纳评估分析

中华人民共和国应急管理部|应急科普丨汛期若遇雷击，如何急救？

#小筱明星show#教你用一款衣服穿出不同种类的风格，衣柜都空了？看袁姗姗穿搭

新手怎么做亚马逊卖家?个人在亚马逊上开店需要注意些什么-

有限公司|那可是家大公司？要流量也要守法制

中国传统文化之春节中国春节

氢氧化钙溶解度曲线氢氧化钙溶解度

曝电影导演协会提名名单胡歌易烊千玺争年度男主

太极拳内功心法之研究太极内功心法

浙江温岭一村庄二层楼民房发生局部倒塌造成1死3伤

「皮球儿妈妈」选对月子中心很重要，了解以下几点，就能避免入坑，坐好月子

王治郅|「王治郅不归事件始末 03」拯救大兵王治郅

黑叔科技卖口罩遭删号血本无归！亚马逊中国：这种行为不能容忍

DOCO热历史：美国的南亚移民女性更易遭受家庭暴力？原因或许有这几点

金寨翠眉是什么茶,江苏有哪些好茶

养血美容豆浆里的补菜是什么？

憋在心里的东西多了，应该咋办

女晚上脚燥热,晚上脚燥热女晚上脚燥热

怀旧服|魔兽世界怀旧服军衔系统详细资料

学霸|有个学霸对象是什么体验？他教我学这学那，我只学会打麻将