1. 首页
  2. 课程学习
  3. Java
  4. 使用Maven整合Kafka实现生产者和消费者

使用Maven整合Kafka实现生产者和消费者

上传者: 2023-04-21 22:21:06上传 ZIP文件 208.84KB 热度 13次

使用Maven整合Kafka包括生产者,消费者Kafka各种配置//1.设置参数Properties props = new Properties(); props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "81.68.232.188:9092,81.68.232.188:9093,81.68.232.188:9094"); //把发送的key从字符串序列化为字节数组props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName()); //把发送消息value从字符串序列化为字节数组props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializ

用户评论