我正在运行一些java 8 Kafka应用程序，其中一些是Kafka流，其他的是简单的生产者/消费者。 对于它们中的每一个，都没有功能问题，它们在大多数时间都运行得很好。但是，对于它们中的每一个，我都会得到SaslAuthenticationException的临时出现。由于它们大约每隔几周发生一次，我不确定如何复制/推断根本原因： 错误： Failed to create channel due
浏览 488提问于2019-04-29得票数 0
我能够使用Kafka终端向主题发送/消费消息，并且能够通过Conduktor监视一切。但不幸的是，我无法通过我的Scala应用程序使用Alpakka连接器来使用msgs。: ports: environment:
KAFKA_BROKER_ID16:58:34.701 INFO [org.apache.kafka.com
浏览 1提问于2020-03-26得票数 3
回答已采纳
我有一个合流卡夫卡的消费者写在戈朗。我正在尝试将它部署到PKS集群中。卡夫卡配置是这样的，kafka.security.protocol=SASL_SSL我需要用SASL_SSL协议为GSSAPI机制配置Dockerfile。/main
CMD ["/
浏览 19提问于2022-11-28得票数 1
我想使用docker-compose创建一个本地的kafka设置，它非常紧密地复制了融合云中的安全kafka设置。我在Confluent Cloud中拥有的集群可以使用 { "sasl.mechanism": "secret",
"group.id": &
浏览 0提问于2021-08-03得票数 0
是否有一种方法可以配置kafka，使复制通信发生在一个网络上，而消费者通过另一个网络连接。从文档中可以看出，代理和消费者都将使用advertised.listeners参数。我想把这里的交通分开。
浏览 0提问于2018-03-23得票数 2
回答已采纳
1回答
消息没有被消耗掉
、、、
我在Spring的application.properties文件中添加了以下配置和Camel实现，但是消息并没有被消耗。我错过任何配置了吗？有没有使用kafka协议和Camel从Azure事件中心实现消费者的指针？bootstrap.servers=NAMESPACENAME.servicebus.windows.net:9093sasl.mechanism" password="{YOUR.EVENTHUBS
浏览 4提问于2021-10-11得票数 0
回答已采纳
我在通过kafka库连接Event Hub时出现以下异常。:687) ~[kafka-clients-2.2.1.jar!:501) ~[kafka-clients-2.2.1.jar!~[kafka-clients-2.2.1.jar!消费者属性如下所示： bootstrap.servers=XXX-topics.servicebus.windows.net:9093sasl.mechanism
浏览 57提问于2020-01-24得票数 4
下面来自Mulesoft的知识文章说(只有Kafka连接器版本3.0.6，3.0.7，3.0.8，3.0.9和3.0.10支持具有GSSAPI机制的SASL_SSL安全协议。当前的Kafka连接器版本4.0.0不支持SASL_SSL，因为存在一个已知的问题SE-15680。)这个问题仍然存在(我在Mulesoft发布说明中看到的最新Kafka连接器是4.4.0)。我尝试在发行说明中
浏览 46提问于2020-12-08得票数 0
回答已采纳
4回答
- zookeeper KAFKA_BROKER_ID: 1 KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
KAFKA_ADVERTISED_
浏览 80提问于2018-12-03得票数 26
回答已采纳
我遇到了一个问题，试图从一个汇合的云集群复制到另一个。我一直在跟踪关于如何做到这一点的汇合文档，但是我遇到了一致的失败，我不得不假设这是由于我的配置中的一个错误造成的。": "source-broker:9092", "src.kafka
浏览 26提问于2020-07-14得票数 0
1回答
我一直在尝试理解apache beam、confluent和dataflow与python 3.8和beam 2.7的集成--所希望的结果是构建一个管道(它将在数据流上运行)，它消耗了来自合流kafka这是我正在使用的代码：from apache_beam.io.kafka import ReadFromKafka
from apache_beam.options.pipeline_options造成此错误的原因似乎是，由于我收到了
浏览 6提问于2022-04-20得票数 1
回答已采纳
;
import org.apache.kafka.clients.admin.AdminClientConfig;import org.springframework.beans.factory.annotation.Autowired; password: XXX
mechanism
浏览 5提问于2022-09-07得票数 0
我正在使用debezium来配置使用SASL_SSL的kafka connect。而SASL身份验证配置我可以执行如下操作： security.protocol=SASL_SSLsasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModulerequired username=${KAFKA_USERNAME} password=${KAFK
浏览 159提问于2021-10-11得票数 0
EventHubs命名空间是使用Kafka enabled标志创建的。String eventHubsPassword = "org.apache.kafka.common.security.plain.PlainLoginModule " + "&requestTimeoutMs=30000" +
"&securityProt
浏览 34提问于2019-07-04得票数 0
回答已采纳
1回答
我过去曾为Kafka客户设置过身份验证。我.我提到过：
KafkaClient { LoginStringClaim_sub="admin";这基本上增加了卡夫卡客户端的OAuth身份验证。问题是-我可以在<
浏览 2提问于2019-02-06得票数 1
回答已采纳
我正在Windows上运行我的客户端，并且能够验证CA权限是否存在，并且在受信任的根证书颁发机构中有效。SSL routines:ssl3_get_server_certificate:certificate verify failed: (after 73ms in state CONNECT)我怀疑用户帐户可能无法访问CA存储，所以我使用我的个人帐户(相对于服务主体)运行了应用程序，并遇到了同样的问题。我还试图导出该证书，并将其放在运行.NET核心应用程序的目录<e
浏览 4提问于2020-08-07得票数 0
我正在尝试使用"SASL_PLAINTEXT"或“明文”连接汇合的Kafka代理，但我得到的错误是broker传输失败。但是，它可以很好地处理"SASL_SSL"协议，但不能处理任何其他安全协议。这是我的密码。const consumer = new Kafka.KafkaConsumer({ &#
浏览 1提问于2019-10-01得票数 1
试图使用我的Kafka生产者应用程序生成一些数据，但是我得到了以下错误：listeners=PLAINTEXT://localhost:909
浏览 2提问于2020-08-04得票数 1
回答已采纳
1回答
我正在尝试设置一个生产者，使用节点rdkafka向IBM中的事件流服务发送消息，但是我无法从服务器接收“就绪”事件。我花了一天的时间想办法解决这个问题，我相信这将取决于我对制片人的配置，但据我所知，我已经做对了。谢谢你能给我的建议。://kafka03-prod02.messagehub.services.eu-gb.bluemix.net]: sa
浏览 0提问于2019-06-13得票数 4
回答已采纳
1回答
是否可以将TDMA与OLSR协议一起用于AD-HOC网络？我必须在Ad-hoc网络上使用基于TDMA的MAC层来进行节点调度。是否可以使用OLSR查找邻居和MAC层，用于Omnet++中的时隙调度
浏览 2提问于2016-06-07得票数 1
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号