在Java(Kotlin)中，如果没有指定bootstrap-server选项而以编程方式创建kafka主题，它是在localhost:9092上默认创建的吗？
在Java (Kotlin)中，如果没有指定bootstrap-server选项而以编程方式创建Kafka主题，它默认是在localhost:9092上创建的。Kafka使用bootstrap.servers属性来指定连接到Kafka集群的地址。如果没有明确指定该选项，Kafka将默认尝试在本地主机上的9092端口上连接到Kafka集群。
Kafka是一个开源的分布式流处理平台，具有高吞吐量、可扩展性和容错性的特点。它广泛应用于实时数据流处理、事件驱动架构、日志聚合等场景。
对于以编程方式创建Kafka主题，可以使用Kafka的Java客户端库，如Apache Kafka的Java客户端、Confluent的Kafka Client等。在创建主题时，需要通过指定连接到Kafka集群的地址来建立与集群的通信。如果不显式指定bootstrap-server选项，Kafka将使用默认值localhost:9092。
腾讯云提供了一系列的云原生解决方案，包括Kafka托管服务-TIM-Kafka、腾讯分布式消息队列TDmq等，用于帮助用户在云端快速构建、部署和管理Kafka集群，提供高可靠、高可用、高扩展性的消息传递服务。您可以访问腾讯云的官方网站了解更多相关产品信息：
这些产品提供了方便易用的界面和API，帮助用户简化Kafka集群的管理和配置，并提供了高可用性和可靠性的保证，使您能够专注于业务逻辑的开发和实施。
相关·内容
我需要以编程方式在不同的引导服务器上创建主题。目前所有创建的主题都在localhost:9092上。在当前的应用配置中，我找不到任何设置此参数的指示。我发现一些示例表明，您确实可以在不指定bootstrap服务器选项的情况下创建</
浏览 17提问于2021-08-16得票数 0
我正在尝试从命令行创建一个新的Kafka主题我得到了错误从文档中，我看到设置num.partitions应该已经完成了这项工作。for consumption, but this will also result in more f
浏览 0提问于2018-02-26得票数 17
回答已采纳
4回答
我有一个Kafka应用程序，它有一个生成主题消息的producer。然后，consumer从主题中获取消息，对给定的消息执行一些逻辑，然后将它们生成到另一个主题。我希望我的应用程序创建2 compacted topics，然后使用它们。如果compacted topics已经存在，只需显示一条消息并继续。:9092,localhost:9093");
props.put(&qu
浏览 1提问于2018-11-20得票数 7
回答已采纳
3回答
我是卡夫卡的新手，并试图在我的本地机器上创造一个新的话题。bin/kafka-server-start.sh -daemon config/server.propertiesbin/kafka-topics.sh --create -–bootstrap-serverlocalhost:9092 -–replication-factor 1 -–part
浏览 1提问于2019-09-05得票数 3
回答已采纳
我已经在Windows 10上配置了kafka_2.11-2.3.0和ApacheZooKeep-3.5.5-bin。但是在运行主题创建命令时，我得到了以下错误：
C:\kafka_2.11-2.3.0>.\bin\windows\kafka-topics.bat --create --bootstrap-server 127.0.0.1:2181 --partitions 1 --replication-factorat org.apache.
浏览 7提问于2019-10-14得票数 14
回答已采纳
我是新来卡夫卡的。当我在命令行中运行快速入门示例时，我发现我不能在命令行中创建多个使用者。我用3个分区构建了一个名为test的主题，我还在这个主题上构建了一个生产者。然后我想创建两个不同的消费者，在这个主题上共享一个名为test1的相同的消费者组。我像下面这样运行了两次命令：
bin/kafka-console-cons
浏览 0提问于2014-10-10得票数 15
我想通过时间戳重置卡夫卡消费群的偏移量。但当我使用以下命令时：我收到以下错误消息：
注意:这将只显示使用Java使用
浏览 7提问于2017-11-20得票数 21
回答已采纳
我在Ubuntu上安装了Kafka，并尝试使用shell文件测试一个简单的场景：bin/kafka-console-producer.sh --bootstrap-server localhost:
浏览 0提问于2020-08-18得票数 1
回答已采纳
1回答
我对mongo使用Kafka连接(源代码)，连接工作人员正在运行，但它不是将数据写入Kafka主题，而是使用源连接器和连接器的以下配置文件：tasks.max=1pipeline=[]change.stream.full.document=updateLookup bin/kafka-co
浏览 10提问于2020-01-22得票数 0
7回答
我需要找到一种向卡夫卡索要一份主题清单的方法。我知道我可以使用包含在kafka-topics.sh目录中的bin\脚本来完成这个任务。一旦我有了这个列表，我需要每个主题的所有消费者。我无法在该目录中找到脚本，也无法在kafka-consumer-api库中找到允许我这样做的类。
这背后的原因是我需要找出主题的偏移量和消费者的偏移
浏览 7提问于2015-09-21得票数 95
回答已采纳
6回答
我是Kafka的新手，正在运行一个简单的kafka消费者/生产者示例，就像和上给出的一样。当我从终端运行consumer时，consumer正在接收消息，但我无法使用Java代码进行侦听。我也在StackoverFlow (链接：，)上搜索了类似的问题，并尝试了这些解决方案，但似乎没有什么对我有效。Kafka版本: pom使用kafka_2.10-0.10.2.1和对应<
浏览 6提问于2017-06-26得票数 7
如何获取、设置或重置Kafka Connect连接器/任务/接收器的偏移量？我可以使用运行kafka.admin.ConsumerGroupCommand的/usr/bin/kafka-consumer-groups工具来查看我所有常规Kafka消费者组的偏移量。但是，Kafka Connect任务和组不会显示在此工具中。类似地，我可以使用zookeeper-shell连接到Zooke
浏览 1提问于2016-06-09得票数 16
回答已采纳
在使用命令行在kafka中使用消息时，是否知道如何设置组名。我尝试使用以下命令：'config' is not a recognized optionbin/kaf
浏览 0提问于2016-07-24得票数 26
回答已采纳
25回答
我把一条太大的信息推到了本地机器上的kafka消息主题中，现在我收到了一个错误：
kafka.common.InvalidMessageSizeException: invalid message size在这里增加fetch.size并不理想，因为我实际上不想接受那么大的消息。
浏览 25提问于2013-04-29得票数 250
回答已采纳
我想删除一个Kakfa消费者组，这样当应用程序创建一个消费者并订阅一个主题时，它可以从主题数据的开头开始。我尝试正常的语法： sudo /usr/bin/kafka-consumer-groups --new-consumer --bootstrap-server localhost:9092 --delete如果我尝试使用zookeeper变体： sudo /usr/
浏览 253提问于2017-03-03得票数 20
回答已采纳
来创建主题。一旦应用程序启动，我可以在kafka中看到主题，但我看不到配置的log.retention.minutes或cleanup.policy。
如果我指定了特定主题的配置，它就会起作用。不能在代理级别配置日志保留和清理吗？当它在主题级别定义时，它显示了配置，但在代理级别，它没有显示任何配置。我运行describe命令进行了仔细检查，现在可以看到cleanu
浏览 69提问于2021-05-31得票数 0
我从Apache开始，它是一个简单的生产者，Java的消费者应用程序。我正在使用kafka-clients版本的0.10.0.1并在Mac上运行它。我创建了一个名为replicated_topic_partitioned的主题，它有3个分区，复制因子为3。
我在2181港开了动物园管理员。我在端口9092、9093和9094分别启动了三个id为1、2和3的
浏览 1提问于2019-08-21得票数 0
我正在试用kafka-console-producer.sh。我在控制台上输入一些东西，然后按回车键，我得到了大量的堆栈跟踪，就像这样。感谢您的指点。./bin/kafka-console-producer.sh --broker-list localhost:2181 --topic test我使用以下内容来设置我的</
浏览 3提问于2014-11-25得票数 14
回答已采纳
到目前为止，我还没有看到一个python客户端可以显式地实现主题的创建，而不使用配置选项自动创建主题。
浏览 1提问于2014-09-25得票数 40
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
