腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
通过
终端
关闭
Kafka
、
、
嗨,我是newby
Kafka
,我成功地在windows中启动了
Kafka
服务器(
通过
终端
),遵循以下文档:https://dzone.com/articles/running-apache-
kafka
-on-windows-oshttps://
kafka
.apache.org/quickstart 我的问题很简单,我应该如何
通过
windows中的命令
终端
正确
关闭
<
浏览 96
提问于2019-03-22
得票数 3
回答已采纳
2
回答
如何使用ansible在后台运行
kafka
broker启动脚本
、
、
、
、
如何在后台运行用ansible编写的
Kafka
broker启动脚本,当我正常运行它时,它在前台执行,我无法恢复对
终端
的控制,如果我
关闭
终端
或Ctrl+c它们,
Kafka
broker将被停止 我的目标是在CLI上启动
Kafka
broker之后,我需要在该
终端
上运行几个命令来执行其他一些任务。ansible kafkabrokers -a "~/
kafka
_2.11-0.9.0.0/bin/
kafka<
浏览 5
提问于2016-03-29
得票数 1
回答已采纳
2
回答
如何在后台运行
Kafka
连接-Distributed.sh(守护进程)?
、
我
通过
ssh连接到远程主机,然后运行
终端
现在无法输入。我试过-daemon选项,但它什么也做不了那么,我如何在守护进程模式下运行连接分发呢?
浏览 5
提问于2020-04-30
得票数 1
1
回答
Kakfa本地shell窗口
关闭
时间
、
、
我是
kafka
的新手,并遵循本教程我使用此命令列出主题,但列出的主题窗口
关闭
,没有足够的时间让我看到。
浏览 17
提问于2021-05-19
得票数 0
5
回答
Kafka
从Python脚本启动时
kafka
-server-stop.sh不工作
、
、
在远程节点上部署了一些Apache
Kafka
实例后,我观察到
Kafka
存档中的
kafka
-server-stop.sh脚本出现了问题。#!,它也可以工作:但在我的远程节点上start man
浏览 2
提问于2014-08-29
得票数 18
1
回答
运行apache
kafka
时
、
当我尝试使用以下命令启动服务器时我得到以下错误 是否有任何方法解决此问题,而不更改环境变量中的JAVA_HOME。
浏览 1
提问于2019-02-26
得票数 0
1
回答
在WSL2 Ubuntu中使用Python的
Kafka
消费者/生产者
、
、
因此,我正在用以下两种在WLS2 Ubuntu内部(即
通过
localhost:9092)进行通信的方法来测试这一假设:步骤2:在
终端
T3中生成消息 echo "Hello, World" | ~/
kafka
/bin/
kafka
-console-producer.sh --broker-list localhost:9092 -
浏览 2
提问于2021-06-09
得票数 1
回答已采纳
1
回答
Kafka
:命令列出一个主题的所有消费者组?
、
、
kafka
-consumer-groups --bootstrap-server localhost:9092 --describe --group webapi-groupError我也试过:但什么都没发生。编辑:开火:
终端
窗
浏览 2
提问于2020-09-14
得票数 2
1
回答
尝试检索组详细信息时,
Kafka
消费者组不存在
、
我正在尝试
通过
终端
中的以下命令来描述
kafka
消费群: ./
kafka
-consumer-groups.sh --bootstrap-server $IP:$PORT --describe --group $GROUPID 我可以
通过
以下命令获取$GROUPID/
kafka
-consumer-groups.sh --bootstrap-server $IP:$PORT --list 回应是: b'TestProcess' 但在尝试
通过</e
浏览 142
提问于2019-05-26
得票数 2
回答已采纳
1
回答
用Python脚本和netcat转发消息
、
、
、
、
我正在尝试将
终端
输出流(在
终端
T1中)转发到本地主机端口,在
终端
T2上监听。然后,使用一个简单的Python套接字脚本来捕获该流数据并打印出来。我引用了ubuntu命令的和Python脚本的:nc -l 2003.bin/
kafka
-console-consumer --topic <topic
浏览 1
提问于2021-06-18
得票数 0
回答已采纳
2
回答
kafka
是否有任何默认的web UI
、
、
1)
Kafka
是否有默认的web UI?任何解决方案都将受到高度赞赏。 谢谢。
浏览 1
提问于2018-03-21
得票数 9
回答已采纳
3
回答
重新启动后卡夫卡主题不再存在。
、
通过
从
kafka
安装目录运行以下命令,我在本地
kafka
集群中创建了一个主题,其中包含3个服务器/代理
通过
从<e
浏览 6
提问于2015-12-01
得票数 4
回答已采纳
1
回答
Kafka
流应用程序用户偏移量在重新启动时被重置为最早
、
、
我们有一个卡夫卡流应用程序,正在经历奇怪的行为。当作业被终止并重新启动时,使用者组将其偏移量重置为最早,所有旧记录都将被重新处理。"buffered.records.per.partition": 512000, "commit.interval.ms": 30000, "acks": "all", "proces
浏览 3
提问于2019-10-16
得票数 0
回答已采纳
3
回答
卡夫卡TOPIC_AUTHORIZATION_FAILED
、
、
[main] INFO org.apache.
kafka
.common.utils.AppInfoParser -
Kafka
version : 0.10.0.0[main] WARN org.apache.
kafka
.clients.NetworkClient - Error while=/home/
浏览 6
提问于2016-10-23
得票数 4
回答已采纳
1
回答
当zookeeper
关闭
时,Spring云流不会抛出异常
、
、
我正在使用
kafka
包附带的zookeeper的
kafka
。我还使用了spring cloud stream和
kafka
活页夹。我想看看如果zookeeper
关闭
会发生什么,而
kafka
代理正在运行。我
通过
spring cloud stream源给
kafka
主题发了一些东西。然而,我的物品不在
kafka
队列中。这是预期的行为,还是bug?如果zookeeper
关闭
了,有什么我可以配置的东西来得到一个异常返回吗?
浏览 0
提问于2017-08-11
得票数 1
2
回答
基于并行度管理的
Kafka
流容错
、
、
、
、
KafkaStream将使用这些事件作为
终端
操作,并将事件集中在一起,比如1000个事件,并将其写入AWS S3。问题 :: 我希望应用程序是容错的,不想丢失消息。个线程都在运行并试图将事件放在S3中,在这种情况下会发生崩溃,因为KafkaStream有( enable.auto.commit = false ),而且我们不能手动提交偏移量,而且所有线程都消耗了来自
Kafka
在崩溃场景中,我应该如何处理这个问题,以及如
浏览 4
提问于2020-11-23
得票数 0
3
回答
当粘贴到Linux中的
终端
时,行长度是否有限制?
、
、
、
、
我正在尝试从
kafka
-console-producer.sh发送消息,这是if [ "x$
KAFKA
_HEAP_OPTS" = "x" ]; thenfi exec $(dirname$0)/
kafka
-run-class.sh
kafka
.tools.ConsoleProducer "$@"
浏览 0
提问于2021-04-06
得票数 24
回答已采纳
1
回答
MinGW安装在windows中,但在运行时仍会引发错误
、
、
import ("fmt"引发的错误是检查%PATH%变量中的可执行文件gcccgo: C compiler &quo
浏览 12
提问于2022-08-12
得票数 1
回答已采纳
1
回答
Ubuntu .profile和.bashrc有问题
、
、
、
、
我目前正在
通过
一个卡夫卡在线设置教程。它说要将
kafka
目录的路径添加到我的.profile文件中,如下所示:在那之后,我在$PATH上做了一个回音,我可以看到卡夫卡路径被添加到路径中。我看到在
终端
上,我没有得到我的用户名,这是一个空白的
终端
窗口。然后我编辑了.bashrc以删除我添加的行
浏览 3
提问于2018-10-13
得票数 4
回答已采纳
4
回答
是什么导致zookeeper客户端会话超时
、
运行了几个小时后,整个拓扑都
关闭
了。我检查了工人日志,找到了这些日志。正如它所说的,zookeeper客户端会话超时并导致重新连接。我怀疑这与我损坏的拓扑结构有关。
浏览 1
提问于2016-03-01
得票数 12
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
通过Pipelinedb使用SQL查询Kafka实时流数据
NET Core使用NLog通过Kafka实现日志收集
通过 Web 浏览器访问终端 rtty
Linux 主机/终端通过命令查询公网 IP 地址
网站暂时关闭 请通过微信续借
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券