我有一个要求，我们必须通过一个单独的休息点来验证系统的健康检查。这个想法是通过kafka client.Does获取集群中主动运行的kafka节点的数量和它们的IP，kafka在客户端提供任何API来获取这些信息？
浏览 15提问于2018-07-20得票数 0
2回答
如何生成和使用来自不同服务器的消息？我试过了Quickstart教程，但是没有关于如何设置多服务器集群的说明。我的脚步1)bin/zookeeper-server-start.sh config/zookeeper.properties服务器B
1A)bin&#
浏览 6提问于2017-04-03得票数 1
1回答
我有Istiov1.6.4的k8s集群。默认情况下，侧插入是禁用的。我让卡夫卡集群在这个k8s上运行，安装了strimzi操作符。卡夫卡集群的工作没有任何问题时，卡夫卡以及客户端吊舱没有注入Istio代理。我的问题是:当我用kafka客户端和Istio代理注入创建一个吊舱时，我无法连接到Kafka集群。客户端的
浏览 4提问于2020-07-09得票数 7
我很困惑地看码头-撰写文件，所以我想问我的问题在这里。在大多数示例中，我看到这样的配置： image: confluentinc/cp-enterprise-kafka:5.3.1我想了解几件与此相关的事情：配置代理的数量</e
浏览 2提问于2020-10-08得票数 5
回答已采纳
我们有一个生产卡夫卡集群，最近被污染了一堆新的话题。Kafka集群具有以下设置：delete.topic.enable=false
经过调查，我发现这些主题是由一个使用KafkaStream的createTopic方法的客户团队创建的：org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster#createTopic(java.lang.
浏览 2提问于2017-12-17得票数 4
回答已采纳
卡夫卡是新来的。这个处理0.8。
我看到有查询分区信息、主题等的方法，但是我看不出如何动态地创建一个主题。
浏览 4提问于2015-12-17得票数 8
回答已采纳
我正在使用Apache，并且在我的Flink任务节点上得到了这个错误。当我重新启动我的Flink节点并重新部署作业时，它运行得很好。当时这些经纪人似乎也很好。at org.a
浏览 13提问于2020-02-20得票数 0
回答已采纳
官方的.Net客户端似乎只提供了消费者和生产者功能。
(根据我对Kafka streams的记忆，很久以前)我相信Kafka Streams处理器总是运行在运行Kafka本身的JVM上。在这种情况下，这基本上是不可能的。
浏览 0提问于2018-02-16得票数 13
回答已采纳
1回答
我已经建立了一个融合云多区域集群，它是用一台引导服务器创建的。在创建集群时，没有选择服务器数量的设置。即使在创建之后，我也不能编辑引导服务器的数量。我想知道如何增加融合云kafka集群中的服务器数量。
浏览 64提问于2021-06-30得票数 0
回答已采纳
我在我的mac上的minikube k8集群的Pod上运行了一个landoop kafka镜像。我有两个不同的服务来公开用于模式注册的端口8081和用于代理的端口9092。我已经在我的NodePort服务中映射了端口8081 -> 30081和9092 -> 30092，以便我可以从集群外部访问它。但是，当我尝试运行控制台消费者或我<
浏览 86提问于2018-02-13得票数 3
KAFKA客户端(生产者和消费者)通过连接到一个已配置的引导服务器来发现拓扑，从那时起，它将直接与集群中的这些代理节点一起工作。有了这个标准的东西，我们可以通过更改引导服务器来更改生产者和消费者，而无需重新启动它们来使用不同的集群吗？我们是否可以在不重新启动客户端的情况下更改引导服务器配置？有
浏览 28提问于2019-05-28得票数 0
回答已采纳
1回答
我有一个在yarn-client (客户端的驱动程序)中运行的spark-submit作业，它通过Kafka读取和发送消息。在我的集群上，只有Kafka代理节点有Kafka jars，我不希望我所有的节点都是Kafka客户端。这意味着我的Spark作业必须从客户端服务器加载(-- jars ) Kafk
浏览 0提问于2018-04-10得票数 0
1回答
我在AWS上运行了一个Kafka集群。我想从我的应用服务器用标准的kafka-控制台-使用者连接到集群。应用服务器可以通过SOCKS代理访问互联网。不需要认证。
我如何告诉卡夫卡客户端通过代理连接？我尝试了很多事情，包括将标准的JVM代理参数添加到kaka-run-class.sh脚本中。但我还是有一个连接被拒绝的错误。exec
浏览 4提问于2017-11-30得票数 7
我一直在尝试从我的React应用程序中将这些数据(主题)读取到我的MSK集群中，我发现可以帮助我的工具和信息很少，但我没有成功
如何从MSK集群中获取此数据并将其显示在React表中？我找到的一些项目：、、、
浏览 19提问于2021-08-06得票数 0
1回答
我正在尝试设置一个代理服务器(java中的首选服务器)，它可以将我的连接流传递给kafka broker。Client (Consumer/Producer) <--> [PROXY SERVER] <--> Kafka Broker
我的用例是使用kafka提供的数据，但是配置参数应该代理给kafka broker例如bootstrap.servers=xx.xx.xx.xx:90
浏览 1提问于2019-05-22得票数 3
目前我们使用Apache NiFi通过Kafka consumer消费消息。kafka客户端的输出连接到hive处理器。
我正在研究如何在nifi集群上运行kafka消费者实例。我有3个节点的nifi集群和一个有3个分区的kafka主题，我希望kafka消费者能够在每个节点上运行，这样每个消费者可以从一个主题分
浏览 3提问于2019-08-04得票数 0
我们在生产环境中有一个安全的Kafka集群(使用TLS加密、基于证书的客户端身份验证和ACL)。我正在尝试弄清楚如何使用适当的设置配置Flink Kafka连接器，以便它可以安全地连接到我们的Kafka集群。Flink可以做到这一点吗？我是否必须通过属性传递安全配置内容？我们的Flink集群运行在Kuberne
浏览 39提问于2019-08-14得票数 1
有多个代码示例可用(其中之一是)，其中实现了KafkaProducer和KafkaConsumers，并且可以单独启动。props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, IKafkaConstants.KAFKA_BROKERS
浏览 3提问于2018-08-03得票数 2
我们在一台服务器上托管了Hazelcast集群，在同一区域的不同服务器上的不同应用程序使用Hazelcast Jet客户端实例通过管道聚合来自Kafka源的数据。在此设置中，Jet客户端实例是否发送从Kafka源Hazelcast集群接收的数据，这将涉及大量IO，或者当我们创建管道时，Hazelcast集群本身创建到Kafka<
浏览 22提问于2019-01-25得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
