腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
在
Java
(
Kotlin
)
中
,
如果
没有
指定
bootstrap-server
选项
而以
编程
方式
创建
kafka
主题
,
它是
在
localhost
:
9092
上
默认
创建
的
吗
?
java
、
kotlin
、
apache-kafka
、
spring-kafka
我需要以
编程
方式
在
不同
的
引导服务器
上
创建
主题
。目前所有
创建
的
主题
都在
localhost
:
9092
上
。在当前
的
应用配置
中
,我找不到任何设置此参数
的
指示。我发现一些示例表明,您确实可以
在
不
指定
bootstrap服务器
选项
的
情况下
创建</
浏览 17
提问于2021-08-16
得票数 0
4
回答
Kafka
创建
默认
分区数
主题
apache-kafka
我正在尝试从命令行
创建
一个新
的
Kafka
主题
我得到了错误从文档
中
,我看到设置num.partitions应该已经完成了这项工作。for consumption, but this will also result in more f
浏览 0
提问于2018-02-26
得票数 17
回答已采纳
4
回答
如何
创建
卡夫卡紧凑
的
主题
java
、
apache-kafka
我有一个
Kafka
应用程序,它有一个生成
主题
消息
的
producer。然后,consumer从
主题
中获取消息,对给定
的
消息执行一些逻辑,然后将它们生成到另一个
主题
。我希望我
的
应用程序
创建
2 compacted topics,然后使用它们。
如果
compacted topics已经存在,只需显示一条消息并继续。:
9092
,
localhost
:9093"); props.put(&qu
浏览 1
提问于2018-11-20
得票数 7
回答已采纳
3
回答
-这不是公认
的
选择
apache-kafka
、
apache-zookeeper
、
kafka-topic
我是卡夫卡
的
新手,并试图
在
我
的
本地机器
上
创造一个新的话题。bin/
kafka
-server-start.sh -daemon config/server.propertiesbin/
kafka
-topics.sh --create -–
bootstrap-server
localhost
:
9092
-–replication-factor 1 -–part
浏览 1
提问于2019-09-05
得票数 3
回答已采纳
7
回答
在
端口2181
上
执行
Kafka
时出错-
主题
命令:超时等待节点分配。OS赢10
windows
、
apache-kafka
我已经
在
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
回答已采纳
5
回答
在
Kafka
命令行
中
创建
多个消费者
apache-kafka
我是新来卡夫卡
的
。当我
在
命令行
中
运行快速入门示例时,我发现我不能在命令行
中
创建
多个使用者。我用3个分区构建了一个名为test
的
主题
,我还在这个
主题
上构建了一个生产者。然后我想
创建
两个不同
的
消费者,在这个
主题
上共享一个名为test1
的
相同
的
消费者组。我像下面这样运行了两次命令: bin/
kafka
-console-cons
浏览 0
提问于2014-10-10
得票数 15
3
回答
kafka
0.11按日期对消费者组重置偏移量
apache-kafka
、
kafka-consumer-api
我想通过时间戳重置卡夫卡消费群
的
偏移量。但当我使用以下命令时:我收到以下错误消息: 注意:这将只显示使用
Java
使用
浏览 7
提问于2017-11-20
得票数 21
回答已采纳
1
回答
为什么我
的
ProducerBuilder类
在
.Net核心控制台中
的
消息
没有
被.Net消费外壳所消耗?
c#
、
ubuntu
、
apache-kafka
、
publish-subscribe
、
kafka-producer-api
我
在
Ubuntu
上
安装了
Kafka
,并尝试使用shell文件测试一个简单
的
场景:bin/
kafka
-console-producer.sh --
bootstrap-server
localhost
:
浏览 0
提问于2020-08-18
得票数 1
回答已采纳
1
回答
卡夫卡蒙戈召集人
没有
按预期工作。
mongodb
、
apache-kafka
、
apache-kafka-connect
我对mongo使用
Kafka
连接(源代码),连接工作人员正在运行,但它不是将数据写入
Kafka
主题
,而是使用源连接器和连接器
的
以下配置文件:tasks.max=1pipeline=[]change.stream.full.document=updateLookup bin/
kafka
-co
浏览 10
提问于2020-01-22
得票数 0
7
回答
卡夫卡消费者名单
apache-kafka
、
kafka-consumer-api
我需要找到一种向卡夫卡索要一份
主题
清单
的
方法。我知道我可以使用包含在
kafka
-topics.sh目录
中
的
bin\脚本来完成这个任务。一旦我有了这个列表,我需要每个
主题
的
所有消费者。我无法
在
该目录中找到脚本,也无法
在
kafka
-consumer-api库中找到允许我这样做
的
类。 这背后
的
原因是我需要找出
主题
的
偏移量和消费者
的
偏移
浏览 7
提问于2015-09-21
得票数 95
回答已采纳
6
回答
简单
的
Kafka
消费者
没有
收到消息
java
、
maven
、
apache-kafka
、
kafka-consumer-api
我是
Kafka
的
新手,正在运行一个简单
的
kafka
消费者/生产者示例,就像和
上
给出
的
一样。当我从终端运行consumer时,consumer正在接收消息,但我无法使用
Java
代码进行侦听。我也
在
StackoverFlow (链接:,)
上
搜索了类似的问题,并尝试了这些解决方案,但似乎
没有
什么对我有效。
Kafka
版本: pom使用
kafka
_2.10-0.10.2.1和对应<
浏览 6
提问于2017-06-26
得票数 7
3
回答
Kafka
连接偏移。Get/Set?
apache-kafka
如何获取、设置或重置
Kafka
Connect连接器/任务/接收器
的
偏移量?我可以使用运行
kafka
.admin.ConsumerGroupCommand
的
/usr/bin/
kafka
-consumer-groups工具来查看我所有常规
Kafka
消费者组
的
偏移量。但是,
Kafka
Connect任务和组不会显示在此工具
中
。类似地,我可以使用zookeeper-shell连接到Zooke
浏览 1
提问于2016-06-09
得票数 16
回答已采纳
5
回答
使用命令行在
kafka
中使用消息时如何设置组名?
apache-kafka
、
kafka-consumer-api
在
使用命令行在
kafka
中使用消息时,是否知道如何设置组名。我尝试使用以下命令:'config' is not a recognized optionbin/
kaf
浏览 0
提问于2016-07-24
得票数 26
回答已采纳
25
回答
有
没有
办法清除卡夫卡的话题?
apache-kafka
、
purge
我把一条太大
的
信息推到了本地机器
上
的
kafka
消息
主题
中,现在我收到了一个错误:
kafka
.common.InvalidMessageSizeException: invalid message size在这里增加fetch.size并不理想,因为我实际
上
不想接受那么大
的
消息。
浏览 25
提问于2013-04-29
得票数 250
回答已采纳
5
回答
如何删除
Kafka
消费者组重置偏移量?
apache-kafka
、
apache-zookeeper
我想删除一个Kakfa消费者组,这样当应用程序
创建
一个消费者并订阅一个
主题
时,它可以从
主题
数据
的
开头开始。我尝试正常
的
语法: sudo /usr/bin/
kafka
-consumer-groups --new-consumer --
bootstrap-server
localhost
:
9092
--delete
如果
我尝试使用zookeeper变体: sudo /usr/
浏览 253
提问于2017-03-03
得票数 20
回答已采纳
2
回答
log.retention和cleanup.policy - Spring
Kafka
apache-kafka
、
spring-kafka
来
创建
主题
。一旦应用程序启动,我可以
在
kafka
中看到
主题
,但我看不到配置
的
log.retention.minutes或cleanup.policy。
如果
我
指定
了特定
主题
的
配置,它就会起作用。不能在代理级别配置日志保留和清理
吗
?当它在
主题
级别定义时,它显示了配置,但在代理级别,它
没有
显示任何配置。我运行describe命令进行了仔细检查,现在可以看到cleanu
浏览 69
提问于2021-05-31
得票数 0
2
回答
如何在同一
主题
下
创建
多个卡夫卡消费者群体
apache-kafka
、
consumer
下面是需要
的
场景。甚至
Kafka
文档也解释了这个场景,但是
没有
提到如何去做。任何帮助都很感谢!
浏览 4
提问于2019-11-29
得票数 4
回答已采纳
2
回答
Apache使用者不会收到包含多个复制因子
的
主题
消息
java
、
apache-kafka
我从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
2
回答
运行
kafka
-console-producer.sh (0.8.1.1)时出现异常
apache-kafka
我正在试用
kafka
-console-producer.sh。我
在
控制台上输入一些东西,然后按回车键,我得到了大量
的
堆栈跟踪,就像这样。感谢您
的
指点。./bin/
kafka
-console-producer.sh --broker-list
localhost
:2181 --topic test我使用以下内容来设置我
的</
浏览 3
提问于2014-11-25
得票数 14
回答已采纳
7
回答
如何使用Python
在
Apache
Kafka
中
以
编程
方式
创建
主题
python
、
apache-kafka
、
kafka-python
、
kafka-topic
到目前为止,我还
没有
看到一个python客户端可以显式地实现
主题
的
创建
,而不使用配置
选项
自动
创建
主题
。
浏览 1
提问于2014-09-25
得票数 40
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
9.kafka shell脚本用法详解
kafka实战演练,欲走大数据之路的台阶打造,通往的必经之路
关于Kafka producer管理TCP连接的讨论
Kafka技术内幕之概述
kafka的安装及生产消费消息demo以及踩坑记录
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券