shikenn(+) 2022-02-16 19:32 采纳率: 100%
浏览 267
已结题

kafka拉取不到数据

最近有需要用kafka接受消息的项目,学习了一下后仿写了一个消费端拉取数据的代码,但是拉取不到数据,想大家看看到底是什么问题,下面附上代码和日志文件
public static void main(String[] args) {
        //1.创建消费者配置信息
        Properties properties = new Properties();
        //2.给配置信息赋值
        //连接的集群
        properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,
                "10.100.81.64:29092, 10.100.81.67:29092, 10.100.81.68:29092, 10.100.81.69:29092");
        //开启自动提交offset
        properties.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG,true);
        //自动提交offset延迟
        properties.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG,"1000");
        //Key,Value反序列化
        properties.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,
                "org.apache.kafka.common.serialization.StringDeserializer");
        properties.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,
                "org.apache.kafka.common.serialization.StringDeserializer");
        //消费者组
        properties.put(ConsumerConfig.GROUP_ID_CONFIG,"KAFKA_GROUP_hcjlctbb");
        //创建消费者
        KafkaConsumer<String, String> consumer = new KafkaConsumer<>(properties);
        //订阅主题
        consumer.subscribe(Arrays.asList("BLINK_DATASERVICE_khqfwxt_HIVE_OCS_ACLINESEGMENT_20220214",
                "BLINK_DATASERVICE_khqfwxt_HIVE_PWOCS_BREAKER_20220214"));
        while (true){
            //获取数据
            ConsumerRecords<String, String> consumerRecords = consumer.poll(100);
            //解析并打印consumerRecords
            for (ConsumerRecord<String, String> consumerRecord : consumerRecords) {
                System.out.println(consumerRecord.key()+"--"+consumerRecord.value());
            }
        }
    }
没有打印数据,只有运行日志,日志文字量太大,没办法直接贴上来,下面贴出链接,请大家查看

日志文件:链接:https://pan.baidu.com/s/12yGdvppj5LnWTFN2oNqfGA?pwd=6wik 提取码:6wik

各位看看到底是哪里写不对
  • 写回答

4条回答 默认 最新

      报告相同问题?

      相关推荐 更多相似问题

      问题事件

      • 系统已结题 3月15日
      • 已采纳回答 3月7日
      • 创建了问题 2月16日

      悬赏问题

      • ¥20 从零开始汽车自动驾驶相关的软件学习
      • ¥30 操作系统进程实验虚拟机
      • ¥15 yolov5摄像头识别只能检测第一帧图像
      • ¥15 有没有可以下载钉钉群文件视频的软件
      • ¥15 如何用LaTeX打出如下的表格
      • ¥15 程序填空补充完整的代码一共三题
      • ¥15 在MySQL中使用while建表,报错
      • ¥15 python导入pyautogui报错,网上也没有找到解决方法如何解决?
      • ¥15 关于IPSEC和NAT SERVER同时使用的情况下,该如何解决客户端访问服务器的问题
      • ¥15 eclipse项目在idea运行部署到云服务器