zoukankan      html  css  js  c++  java
  • kafka入门(3)- SpringBoot集成Kafka

    1、引入依赖

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

    2、application配置

    spring.kafka.bootstrap-servers=192.168.1.107:9092
    spring.kafka.consumer.group-id=myGroup
    spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
    spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
    spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
    spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer

    3、写消息

    @Component
    public class Sender {
        @Autowired
        private KafkaTemplate kafkaTemplate;
        private Gson gson = new GsonBuilder().create();
    
        public void sendMessage(){
            Message m = new Message();
            m.setId(System.currentTimeMillis());
            m.setMsg(UUID.randomUUID().toString());
            m.setSendTime(new Date());
            kafkaTemplate.send("test1", gson.toJson(m));
        }
    }

    4、读消息

    @Component
    public class Receiver {
    
        private Gson gson = new GsonBuilder().create();
    
        @KafkaListener(topics = "test1")
        public void processMessage(String content) {
            Message m = gson.fromJson(content, Message.class);
            System.out.println(m.getMsg());
        }
    }
  • 相关阅读:
    gitio博客搭建,hexo + NeXT
    [MIsc]JD笔试编程题
    [MATH]Big Integer +
    【Math】GCD XOR 证明
    【Math】最近点对
    【SRM】600#div2 B 枚举
    【Game】组合游戏
    【Game】找出游戏必胜态
    【DP】树形DP 记忆化搜索
    141. Linked List Cycle
  • 原文地址:https://www.cnblogs.com/ijavanese/p/9254687.html
Copyright © 2011-2022 走看看