当我设置kafka代理时，它的URL默认使用 例如"http://kafka-broker-ingress.knative-eventing.svc.cluster.local/example/default“ 我只能从k8集群内的资源发送事件。是否可以使用面向公众的URL设置kafka代理，以便它可以接收来自集群外部</e
浏览 49提问于2021-06-02得票数 1
回答已采纳
我们正在设计一个Kafka集群(至少3个节点)，它将处理来自一组web服务器的事件。由于日志在很大程度上是相同的，我们计划只创建一个主题(比如webevents)外部硬件平衡器是否有助于解决此问题？或者，Kafka配置能否
浏览 0提问于2017-05-26得票数 9
回答已采纳
2回答
未触发死信库
、、
我在代理中定义了用于DLQ的服务。然后，我在序列中设置了一个服务，以有意返回一个非200状态。当我在关联事件命名空间中查看通道调度程序的日志时，我相信我所读到的是它认为有一个失败。下面的日志项来自运行在编织事件命名空间中的通道调度程序荚。它与内存通道或卡夫卡的外观基本相同，即预期的2xx得到500。我的经纪人是这样的：
apiVersion: eventing.knative.de
浏览 18提问于2021-11-30得票数 0
回答已采纳
1回答
卡夫卡在GKE中通过入口暴露
、、、、
在我们的GKE集群中，我有一个使用Strimzi运算符创建的kafka集群。我需要让它暴露在入口上，以允许外部团队为开发目的与其进行交互。我试图在互联网上公开它，但我似乎无法在GKE中找到正确的配置。它需要做一个SSL-通过。这在GKE中支持吗？下面是我正在使用的集群配置。annotations:
kubernetes.io/ing
浏览 7提问于2022-05-26得票数 0
回答已采纳
我让卡夫卡部署并运行在库伯奈特斯集群中。我使用的图像来自码头枢纽-
我有3个kube节点在我的kubernetes集群中。我可以从内部发布/消费kubernetes集群，但我不能从kubernetes集群外部发布/消费，即从外部机器发布/消费，而不是kubernetes集群的一部分。我能够从外部机器到达kube节点--基本上我可以使用name&#
浏览 5提问于2017-01-26得票数 13
我正在尝试设置一个K本机事件管道，其中存在一个容器，该容器接受外部gRPC请求，并将事件激发到代理中以供进一步处理。apiVersion: v1metadata: labels:
eventing.knative.dev/injection: ena
浏览 4提问于2021-05-26得票数 1
回答已采纳
1回答
是否可以将kafka broker上的日志移动到不同的broker？我使用kafka作为事件存储(按照他们网站上的建议)，所以我不会删除日志，我想知道如果我的代理填满了(当我扩展集群时)是否可以将日志移动到另一个代理。此外，当添加新的代理并为其分配分区时，如果我正确理解了来自已移动分区的旧数据将保留在它的原始代理上-这意味着如果
浏览 0提问于2016-05-31得票数 0
在当前的一个项目中，我正在使用一个水槽服务器，以便启动与socket-io websocket的连接，当消费消息时，它会将它们写入kafka主题。我想使用带有ConnectWebSocket处理器的nifi集群，以便使用来自websocket的消息，并最终将它们插入到kafka主题中。nifi集群是否会因为集群中有多个broker处理同一事件而导致topic中的重
浏览 10提问于2020-04-21得票数 0
回答已采纳
4回答
主题通常驻留在broker (服务器进程)中，并且具有多个分区，但它能跨越多个代理或节点(计算机)吗？
也就是说，假设一个主题被分为两个分区，分区-1和分区-2。分区-1是否属于代理-1和分区-2的相同主题属于不同的代理-2或完全不同的节点？
浏览 0提问于2016-07-07得票数 13
回答已采纳
1回答
我用码头，一个是养动物园的，另一个是卡夫卡，我用的是船坞。zookeeper_connect=localhost:2181
2018-07-15 01:31:58,369 INFO打开到服务器localhost/127.0.0.1:2181的套接字连接:2181，启动会话(org.apache.zookeeper.ClientCnxn) 2018-07-15 01:35:40,836 INFO无法从服务器sessionid 0x0读取附加数据，可能的服务器已关闭套接字容器连接到动物园管
浏览 2提问于2018-07-15得票数 2
回答已采纳
2回答
我有一个运行在K8S上的Kafka集群。我正在使用融合的kafka图像，因为我有一个正在工作的外部侦听器。如何添加SSL加密？我应该使用入口吗？我在哪里可以找到好的文档？谢谢
浏览 3提问于2019-11-10得票数 2
1回答
卡夫卡多听众
、、
我已经在AWS中设置了一个Kafka集群，其中有以下监听器和广告监听器：我们使用VPCE来连接帐户内的Kafka集群，因此私有侦听器的主机对于每个帐户都是相同的，并且使用本地私有R53区域。作为一个运行中的集群，所有
浏览 0提问于2019-02-11得票数 0
我一直试图在本地机器上运行一个消费者，连接到运行在GCP中的Kafka服务器。bin/zookeeper-server-start.sh config/zookeeper.propertiesbin/kafka-server-start.shconfig/server.propertiesbin/kafka-co
浏览 11提问于2020-06-18得票数 0
回答已采纳
= new BrokerService();broker.setPersistent(new BrokerPlugin[]{authenticationPlugin});broker.setUseShutdownHook(true);
broker.addConnector(mqtt); 我需要接受来自外部<em
浏览 28提问于2020-10-02得票数 0
回答已采纳
1回答
我对kafka，docker和kubernetes都是新手。我尝试在minikube中运行单节点或多节点kafka集群，并使用.net控制台应用程序向/从kafka broker产生/消费消息。有没有人能给我指点一下.net应用程序的解决方案？使用它，我可以创建一个简单的POC，它可以向kafka经纪人发送消息/从kafka经纪人接收消息？我花了太多的时间来使用和融合的
浏览 0提问于2018-03-29得票数 2
3回答
我试图将我的工作连接到一个容器中，该容器将事件发送到另一个容器中的kafka集群。无论我尝试了什么，我都无法将事件发送到kafka主题--我尝试过telnet和kafkacat到我的kafka的地址侦听器端口，一切都很好：
producer.send('numtest'
浏览 3提问于2020-03-20得票数 2
回答已采纳
1回答
Kafka静态IP与服务发现
、、、、
我有一个三个节点的Kakfa集群，其中还有一个三个节点的Zookeeper来管理它。这个集群的配置如下所示192.168.1.12Kafka端口- 9092Zookeeper端口- 2181
192.168.1.13Kafka，而且通常从我所看到的情况来看，即使在管理大量的Kafka集群时，通常也只有不到10个动物园管理员节点。对于
浏览 6提问于2021-05-14得票数 0
我正在尝试从外部客户端(我的笔记本电脑)连接到我在ec2机器上运行的Kafka集群中的代理。当我尝试从我的本地机器连接时，我得到以下错误：>hiconnect-configs
connect-o
浏览 0提问于2018-09-21得票数 2
我正在使用在minikube上运行kubernetes，我公开了一个外部端口，并成功地使用了来自集群外部的生产者和消费者NAMEAGE1h
brokerimport KafkaConsumer, KafkaProduc
浏览 0提问于2018-07-03得票数 11
我读过很多类似的题目，但他们在这里不能回答我的问题。 - zookeeper - "29092:29092" - 9092 KAFKA_BROKER_IDKAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka</e
浏览 3提问于2020-03-12得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
