[root@linux04 Downloads]# java -cp kafka001-1.0-SNAPSHOT.jar com.bw.Stream.Application
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
Exception in thread "main" org.apache.kafka.common.KafkaException: Failed create new KafkaAdminClient
    at org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:370)
    at org.apache.kafka.clients.admin.AdminClient.create(AdminClient.java:62)
    at org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier.getAdminClient(DefaultKafkaClientSupplier.java:34)
    at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:707)
    at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:628)
    at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:612)
    at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:602)
    at com.bw.Stream.Application.main(Application.java:38)
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers
    at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:66)
    at org.apache.kafka.clients.admin.KafkaAdminClient.<init>(KafkaAdminClient.java:409)
    at org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:363)

 

 
 
 
 
 
 
 
kafka中的错误
 
 
 
 
 
因为我的打的jar包中找不到 主机名称  记得改成自己的
 

 

转载于:https://www.cnblogs.com/JBLi/p/11360075.html
 
  

        # 大数据
      
        # java
      
  
 
 Logo 
Kafka开源项目指南
 
Kafka开源项目指南提供详尽教程，助开发者掌握其架构、配置和使用，实现高效数据流管理和实时处理。它高性能、可扩展，适合日志收集和实时数据处理，通过持久化保障数据安全，是企业大数据生态系统的核心。
 
 
  
更多推荐
  
 
Kafka入门（一） 概述、部署与API的简单使用
 
Kafka概述、部署与API的简单使用
 
avatar Kafka开源项目指南
 
 
基于canal和kafka同步，实现binlog同步ElasticSearch
 
文章目录前言elasticsearch 安装canal安装canal-adapter 安装及配置mysql 安装zk及kafaka安装查看效果注意事项前言中间件版本elasticsearch7.5.2canal1.1.4client-adapter1.1.5-alpha-1zookeeper3.4.13kafka2.6.0mysql5.7.31elasticsearch 安装{"settings"
 
avatar Kafka开源项目指南
 
 
基于 Iceberg 的湖仓一体架构在 B 站的实践
 
背景在B站，每天都有PB级的数据注入到大数据平台，经过离线或实时的ETL建模后，提供给下游的分析、推荐及预测等场景使用。面对如此大规模的数据，如何高效低成本地满足下游数据的分析需求，一直是我们重点的工作方向。我们之前的数据处理流程基本上是这样的：采集端将客户端埋点、服务端埋点、日志、业务数据库等数据收集到HDFS、Kafka等存储系统中，然后通过Hive、Spark、Fl...
 
avatar Kafka开源项目指南