kafka --org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootst

报错内容：

Exception in thread "main" org.apache.kafka.common.KafkaException: Failed to construct kafka consumerat org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:781)at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:635)at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:617)at com.czxy.zy01.Consumer.main(Consumer.java:22)
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.serversat org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:64)at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:698)... 3 more

项目源码:

package com.czxy.zy01;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.KafkaConsumer;import java.util.Arrays;
import java.util.Properties;/*** @author kismet* @date 2020-03-19 15:00*/
public class Consumer {public static void main(String[] args) {Properties props = new Properties();props.put("bootstrap.servers", "hadoop-01:9092");props.put("group.id", "test");props.put("enable.auto.commit", "true");props.put("auto.commit.interval.ms",  "1000");props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");KafkaConsumer<String, String> KafkaConsumer = new KafkaConsumer<>(props);KafkaConsumer.subscribe(Arrays.asList("student"));while (true){ConsumerRecords<String, String> poll = KafkaConsumer.poll(1000);for (ConsumerRecord<String, String> consumerRecord : poll) {System.out.println(consumerRecord.value());}}}

报错原因：

在bootstrap.servers中没有提供可解析的引导url

解决方法：

kafka --org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootst相关推荐

java kafka搭建,Apache Kafka 安装步骤
概览安装过程总共分为 3 大块,第一 Java 环境不必多说,第二 Zookeeper 安装,第三 Kafka 安装. 概念了解 Kafka 有几个重要的概念需要先了解一下名词解释 broker ...
【kafka】Apache Kafka 中的事务
文章目录 1.概述本文为博主九师兄(QQ:541711153 欢迎来探讨技术)原创文章,未经允许博主不允许转载. 1.概述翻译:https://www.confluent.io/blog/tran ...
【kafka】Apache Kafka 0.11版本新功能简介
1.概述转载:https://www.cnblogs.com/huxi2b/p/7098281.html
kafka 发布-订阅模式_使用Apache Kafka作为消息系统的发布-订阅通信中的微服务，并通过集成测试进行了验证...
kafka 发布-订阅模式发布-订阅消息系统在任何企业体系结构中都起着重要作用,因为它可以实现可靠的集成而无需紧密耦合应用程序. 在解耦的系统之间共享数据的能力并不是一个容易解决的问题. 考虑一个企 ...
使用Apache Kafka作为消息系统的发布-订阅通信中的微服务，并通过集成测试进行了验证...
发布-订阅消息系统在任何企业体系结构中都起着重要作用,因为它可以实现可靠的集成而无需紧密耦合应用程序. 在解耦的系统之间共享数据的能力并不是一个容易解决的问题. 考虑一个企业,其中具有使用不同语言和平 ...
基于事件驱动架构构建微服务第12部分：向Apache KAFKA生成事件
原文链接:https://logcorner.com/building-microservices-through-event-driven-architecture-part12-produce-e ...
Apache Kafka简介
什么是Apache Kafka? Apache Kafka是一个分布式流系统,具有发布和订阅记录流的功能. 在另一方面,它是企业消息传递系统. 它是一个快速,水平可扩展和容错的系统. Kafka有四个 ...
Apache Kafka Consumer 消费者集
1.目标在我们的上一篇文章中,我们讨论了Kafka Producer.今天,我们将讨论Kafka Consumer.首先,我们将看到什么是Kafka Consumer和Kafka Consumer的 ...
Apache Kafka 入门 - Kafka命令详细介绍
Apache Kafka 入门 Apache Kafka 入门大概分为5篇博客,内容都比较基础,计划包含以下内容: Kafka的基本配置和运行 Kafka命令详细介绍 Kafka-manager的基本 ...

kafka --org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootst

报错内容：

项目源码:

报错原因：

在bootstrap.servers中没有提供可解析的引导url

解决方法：

kafka --org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootst相关推荐

最新文章

热门文章