2回答
在DCOS上使用Statsd的Kafka指标
apache-kafka、dcos、statsd
我想获取一些指标来监控它，我看到有这样的配置：我在代码中查看了一下，在server.properties.mustache中有一些配置参数：external.kafka
浏览 4提问于2018-01-27得票数 0
1回答
如何查看带有主机、服务器名称和代理列表的kafka主题消息
apache-kafka、kafka-consumer-api
我有kafka主题，服务器名称，端口和经纪人列表。
如何使用这些详细信息查看来自消费者的数据。
浏览 22提问于2018-08-09得票数 1
1回答
OpenShift -何时在创建新应用程序时创建服务？
docker、apache-kafka、openshift、strimzi
我创建了两个应用程序wurstmeister/kafka和zookeeper，如下所示。oc new-app wurstmeister/kafka
oc new-app zookeeper 虽然我可以在我的项目中看到zookeeper服务，但我没有看到Kafka服务。如何让我的其他pods连接到Kafka？通过pod IP地址？但是，service难道不是pods相互连接的方式吗？ 为什么Kafka的</e
浏览 23提问于2019-10-03得票数 0
回答已采纳
1回答
无法通过Docker连接到单节点Kafka服务器
python、docker、apache-kafka、apache-zookeeper、confluent-schema-registry
我尝试通过Docker连接到单节点Kafka服务器，但得到以下错误： image: confluentinc/cp-kafka:latest depends_on: KAFKA_BROKER_ID: 1
KAFKA</em
浏览 4提问于2018-06-19得票数 5
3回答
Kafka Consumer - JMX属性
apache-kafka、jmx
我在端口8081上的kafka代理上启用了JMX。当我在jConsole中查看MBean属性时，我只看到kafka.consumer的以下内容-但是，在中根据Kafka Consumer Metrics确定的</em
浏览 3提问于2016-06-14得票数 1
1回答
如何再运行一次？
apache-kafka、apache-zookeeper
直到30分钟前，Kafka对我来说还很好。我使用的是windows，我使用的命令是：启动zookeeper然后启动kafka服务器。
现在，由于某些原因
浏览 7提问于2020-08-28得票数 1
1回答
启用用于监控kafka的JMX端口
apache-kafka、jmx
使用对的引用，我创建了jmx_local.config并修改了Kafka启动脚本)"/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/bin/java/jmx_local.conf kafk
浏览 43提问于2020-10-22得票数 0
1回答
卡夫卡的pySpark结构化流不输出到控制台进行调试。
python、apache-spark、pyspark、apache-kafka、spark-structured-streaming
下面是我的密码。我尝试了许多不同的选择变体，但应用程序运行，但没有显示消息，这些信息正在编写的每一秒。我有一个使用pprint()的星火流示例，它确认kafka实际上每秒钟都会收到消息。Kafka中的消息是JSON格式的，请参见字段/列标签的架构：from pyspark.sql.types import *
<e
浏览 6提问于2019-12-31得票数 4
回答已采纳
1回答
代理不可用(loadMetadataForTopics) -kafka-节点
node.js、apache-kafka、apache-zookeeper、kafka-node
我的对接者-撰写文件services: container_name: zookeeper container_name: kafka ports: environment:
KAFKA_ZOOKEEPER_CO
浏览 4提问于2020-06-20得票数 0
1回答
Istio K8sObjectOverlay.PathValue列表元素不能工作
kubernetes、istio
[name:kafka] name: kafka targetPort: 9092
这样我就可以将kafka添加到端口列表中。[:value2]的字段路径，其中[key1:value1]是标识列表元素的键值对的选择器，[:value]是标识叶列表中的列表元素的<
浏览 6提问于2020-06-19得票数 4
1回答
在Kafka Connect上为线程监听器端口暴露额外端口
apache-kafka、docker-compose、apache-kafka-connect、confluent-platform
我正在使用Kafka Connect，并在我的连接器插件中启动了一个独立的线程，该插件正在侦听一个端口(比如"9090")。我想使用这个端口来允许应用程序(在kafka环境之外)与我的连接器插件进行通信。 我在docker-compose中运行Kafka Connect (和kafka环境)。问:如何在docker compose中公开端口，以便外部应用程序可以访问我的<
浏览 33提问于2021-10-08得票数 0
回答已采纳
1回答
Kafka-“从源套接字接收到的通道读取的1很可能已经关闭”
sockets、apache-kafka
我首先使用以下命令创建一个主题测试然后，当我尝试使用以下命令向Kafka中的主题插入一条新消息时
/opt/cloudera/parcels/KAFKA<
浏览 7提问于2015-07-22得票数 0
回答已采纳
1回答
配置，覆盖端口
spring、spring-boot、apache-kafka、spring-kafka
我使用Spring Boot + Kafka。这是我目前对Kafka的非常简单的配置：@EnableKafka这种配置工作得很好，并且能够在默认的Kafka端口上连接到Kafka实例：9092
现在我需要更改端口，比方说在9093上。如何更新这个Kafka配置以便能够在9093上连接
浏览 1提问于2017-11-22得票数 3
回答已采纳
1回答
kafka和zookeeper之间的注册流程
docker、registration、apache-kafka、apache-zookeeper、flow
我在尝试对接kafka和zookeeper时遇到了一些问题。提前谢谢。
浏览 1提问于2015-10-12得票数 1
1回答
kafka中的额外随机端口是什么?如何将其设置为绑定到localhost
apache-kafka、port
这发生在主机和docker镜像上，除了著名的9092端口外，还有另一个kafka侦听的动态端口。我使用/usr/local/ kafka /bin/kafka-server-start.sh来运行kafka。ps -ef |grep kafka |grep -v grep |awk '{print $2}'
netstat -tnpl |grep 15
浏览 168提问于2019-09-01得票数 0
1回答
查询Kubernetes中的远程状态存储(交互式查询)
kubernetes、apache-kafka、apache-kafka-streams
是否有关于在部署在Kubernetes中的应用程序实例之间查询远程状态存储的建议？我们的应用程序实例部署有2个或更多副本。基于文档的 .stream() /如果是的话，从这个吊舱到另一个舱的呼叫会被允许吗？这是正确的做法吗？
浏览 2提问于2020-04-17得票数 1
回答已采纳
2回答
使用Nginx Ingress Controller公开多个融合的Kafka Broker
kubernetes、apache-kafka、kubernetes-ingress、confluent-platform
我正在尝试使用ingress nginx公开暴露cp-kafka代理，我碰巧看到了this Stack Overflow question.，答案只显示一个代理暴露在集群之外。例如，如果我有3个代理在运行，我如何使用nginx入口控制器公开所有3个Kafka代理？
浏览 81提问于2021-04-14得票数 0
2回答
Kafka生产者从端口产生数据到主题
apache-kafka、kafka-consumer-api、kafka-producer-api
我是卡夫卡的新手。我想使用Kafka producer来侦听该端口，并将数据流发送到一个主题。
浏览 54提问于2017-08-01得票数 4
回答已采纳
2回答
无法启动Centos 7/Centos 8上的Kafka/动物园管理员服务
apache-kafka、centos、centos7、centos8
路径是正确的，我不知道为什么我不能启动kafka服务，所有行，日志文件等，并没有说问题是什么.:/
我试图安装卡夫卡在我的Centos 7/8，没有问题的描述，我可以弄清楚。ExecStart=/home/kafka/kafka/bin/zookeeper-server-start.sh /home/kafka/kafka/config
浏览 18提问于2020-04-01得票数 0
回答已采纳
1回答
Kubernetes:让有状态集使用相同的外部端口
kubernetes、apache-kafka、port
我有一个带有3个副本的Kafka状态集:我使用的是kafka舵图，可用和confluentinc/Kafka 5.3.1图像。我使用注解来确保每一个都在不同的节点上运行。我想在每个pod上打开相同的外部端口。目前，舵图打开9092内部端口和(31090 +副本数量)作为外部端口。我使用关联来确保pod部署在不同的主机上。我还使用入口连接到AWS上的负载均衡器。运行在不同节
浏览 13提问于2020-02-13得票数 0
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号