EventHubs Kafka使用者的SSL 2.2“接收失败: DotNetCore传输错误”
是指在使用EventHubs Kafka时，使用SSL 2.2进行连接时出现的接收失败和DotNetCore传输错误的问题。
首先，EventHubs是Azure提供的一项托管事件流平台，用于处理大规模实时数据流。Kafka是一种分布式流处理平台，用于构建高性能、可扩展的实时数据流应用程序。
SSL（Secure Sockets Layer）是一种加密协议，用于在网络上提供安全的通信。SSL 2.2是指使用SSL协议的版本2.2。
在使用EventHubs Kafka时，如果使用SSL 2.2进行连接，可能会出现接收失败和DotNetCore传输错误的问题。这可能是由于以下原因导致的：
- 版本兼容性问题：SSL 2.2可能与EventHubs Kafka的某些组件或依赖项不兼容，导致传输错误和接收失败。
针对这个问题，建议采取以下措施来解决：
- 使用更高版本的SSL：尝试使用更高版本的SSL协议，如SSL 3.0或TLS 1.2。这些版本可能与EventHubs Kafka更兼容，可以避免传输错误和接收失败。
- 检查证书和密钥：确保使用的SSL证书和密钥是有效的，并且与EventHubs Kafka的配置相匹配。错误的证书或密钥可能导致传输错误和接收失败。
- 更新相关组件：确保使用的DotNetCore和其他相关组件是最新版本。更新这些组件可能修复一些已知的问题和错误。
- 联系技术支持：如果问题仍然存在，建议联系EventHubs Kafka的技术支持团队，寻求他们的帮助和指导。
腾讯云相关产品推荐： 腾讯云提供了一系列与云计算相关的产品和服务，以下是一些推荐的产品和对应的链接地址：
- 云服务器（ECS）：提供弹性计算能力，支持多种操作系统和应用场景。链接：https://cloud.tencent.com/product/cvm
- 云数据库MySQL版：提供高性能、可扩展的关系型数据库服务。链接：https://cloud.tencent.com/product/cdb_mysql
- 云存储（COS）：提供安全可靠的对象存储服务，适用于各种数据存储需求。链接：https://cloud.tencent.com/product/cos
- 人工智能平台（AI Lab）：提供丰富的人工智能算法和工具，支持开发和部署智能应用。链接：https://cloud.tencent.com/product/ailab
请注意，以上推荐的产品仅供参考，具体选择应根据实际需求和情况进行。
相关·内容
Azure Core2.2应用程序连接到DotNet EventHubs (Kafka)…每周至少一次(从与API相关的Linux服务的输出中)确定报告的多个错误： 失败|rdkafka#consumer:接收失败: SSL传输错误:连接被对等重置( 43431ms状态为UP后) 错误|rdkafka#consumer-1|thrd:组协调器:
浏览 18提问于2019-09-24得票数 0
我们今天遇到了一个问题，一个Kakfa消费者无法连接到任何代理，日志中没有错误消息。当它通过SSL连接并且指向错误的信任库时，它未能连接。但是，虽然在这种情况下，这是由于SSL失败，但我也曾见过其他情况，即使用者无法连接，日志中没有错误消息。
是否有一种方法来配置卡夫卡使用者，以便在使用者无法连接到代理？时记录错误消息--我正在寻找一个通用解决方案，而不是特定于SSL连接问题<em
浏览 1提问于2018-11-07得票数 3
我正在尝试设置Kafka Connect，目的是运行ElasticsearchSinkConnector。 CONNECT_SECURITY_PROTOCOL: SASL_SSL
CONNECT_SASL_KERBEROS_SERVICE_
浏览 0提问于2020-04-06得票数 8
回答已采纳
下面是我正在使用的命令，但是当我创建kafka管道命令时，我得到以下错误: ERROR 1933 ER_EXTRACTOR_EXTRACTOR_GET_LATEST_OFFSETS:无法获得管道的源元数据创建使用者失败: ssl.ca.location失败:没有其他可用的错误信息CREATE PIPELINE ticketmaster_pipeline AS
LOAD DATA <
浏览 0提问于2022-06-30得票数 1
回答已采纳
2回答
我需要使用来自事件源的消息(表示为一个单独的Kafka主题)，它每秒产生大约50到250 k的事件。它只提供一个分区，并且ping相当高(90-100 is )。据我所知，通过阅读Kafka客户机代码，在轮询过程中发出了一个获取请求，并且一旦响应被完全读取，事件/消息就会被解析和反序列化，一旦足够多的事件/消息可用，consumer.poll()将为调用应用程序提供子集较小的获取时间将增加上次响应、解析、反序列化和发送下一个请求与等待下一个请求<em
浏览 2提问于2022-07-20得票数 2
这是每1秒一次的高级使用者轮询。会话暂停10秒钟。心跳间隔3秒。我期望使用者在会话超时后自动重新连接。这是图书馆员的预期行为，消费者可以在循环中简单地调用“消费”，任何这样的网络断开都应该由库自动处理。
我注意到当集群关闭并返回时，使用者能够自动重新连接。生产者没有这个问题，当网络问题马上解决的时候，他们就能生产出没有任何问题的集群。之后) RebalanceCb:本地:撤消分区: LOG-4-COMMITFAIL: state :主:偏移提交(未分配
浏览 8提问于2020-01-16得票数 2
1回答
作为AbortSlowConsumerStrategy的一部分，Active MQ发送一个命令来关闭使用者，如果它发现使用者速度慢，但是在使用者/客户端，故障转移传输协议实现似乎没有处理这个Consumercontrol命令，它失败地说："ERROR: Unknown ConsumerControl.“；是否有更好的方法来中止使用者而不是接收错误？
请注意，使用者在DotNet中
浏览 3提问于2017-04-03得票数 0
回答已采纳
1回答
为了消费来自Kafka的数据，我们可以在一个主题上有多个消费者，完全解耦。那么，在卡夫卡和脉冲星之间存在差异的页面上的no shared consumption (https://streaml.io/blog/pulsar-streaming-queuing)是什么意思？
浏览 19提问于2019-04-26得票数 2
回答已采纳
1回答
我有卡夫卡的克劳德拉经理。Kafka配置为与TLS一起工作，在应用程序端，我有生产者和使用者，它们也具有建立安全连接所需的所有参数。然而，当我的应用程序启动时，kafka消费者开始轮询消息并失败，不确定它是否因为握手异常而失败，这是错误javax.net.ssl.SSLException: U
浏览 0提问于2018-11-26得票数 0
回答已采纳
下面的应用程序是一个简单的使用者，它将所有消息打印到控制台。 'security.protocol': 'SASL_SSL几个小时后，我看到以下错误消息。一旦我重新启动脚本，它就会再次正常工作。：sasl_ssl://kafka08-prod01.messag
浏览 4提问于2017-08-29得票数 2
回答已采纳
1回答
经过很长一段时间的尝试，我终于成功地连接到引导服务器并接收了第一条消息。但没有被反序列化。但是我无法正确地使用它们，所以我可以获得可读的数据。不管我怎么输入它，它总是会抛出一个错误。只有当我在没有任何模式的情况下检索时，我才会得到上面的消息。--from-beginning
这里提出的第一个问题是，我被告知模式的3个urls。我还得到了一个类型指示，但我想直接在kafka中使用整个程序，然后通过kafka连接接收器将
浏览 14提问于2021-12-29得票数 0
回答已采纳
但是，当我试图从主题中读取消息时，会出现未经授权的错误。username="<username>"};
.:34:17,568错误消费者clientId=消费者-控制台-消费者-13840-1，组id=控制台-消费者-13840主题授权失
浏览 8提问于2022-06-21得票数 1
回答已采纳
我正在尝试使用来自组织外部的Kafka集群的消息，这需要身份验证。我正在接收消息，所以大概有些事情是正确的，但是我在日志中得到了这个错误消息：
org.apache.kafka.common.errors.ClusterAuthorizationException:08:54:50.840卡夫卡-管理-客户端-线程/线程-1错误i.m.m.health.indicator.HealthResult -健康指示器卡夫卡报告异常：群集授权
浏览 9提问于2021-09-06得票数 3
回答已采纳
我正在尝试使用"SASL_PLAINTEXT"或“明文”连接汇合的Kafka代理，但我得到的错误是broker传输失败。但是，它可以很好地处理"SASL_SSL"协议，但不能处理任何其他安全协议。这是我的密码。const consumer = new Kafka.KafkaConsumer({
'group.id':'gsuite_consumer'
浏览 1提问于2019-10-01得票数 1
2回答
我们在流处理项目中使用AWS Kinesis，我想知道它是如何确认或注意到已经接收到消息的，而且，如果存在配置它的方法。我在他们的文件里找不到任何东西。因为AWS Kinesis是基于Kafka叉子的，所以它可能是配置此行为的一种方法。
浏览 7提问于2020-11-13得票数 0
回答已采纳
尝试使用SSL证书实现客户端身份验证。接收以下错误。阿帕奇:重新谈判握手失败:客户不接受！？ssl_error_handshake_failure_alert
我认为这是一个配置错误，但未能找到它。附加信息:商业CA服务器证书服务器安全工作，在Apache2.2和乘客中没有问
浏览 0提问于2009-06-03得票数 3
Kafka SSL对等端没有进行身份验证，而是返回匿名错误，当客户端连接代理SASL端口时，它允许在明文或SSL端口上进行连接。在启用SSL的windows系统中，我有kafka 2.2.0，其中kafka broker明文在9092上运行，SSL在9093上运行。，出现了问题摘要中提到的错误。更新：
浏览 2提问于2019-10-11得票数 0
1回答
在kafka使用者中，如果消息的处理时间超过5分钟，则消息是新处理的，我已经将使用者配置为增加"max.poll.interval.ms“和session.timeout.ms。7200000 (2小时) session.timeout.ms= 7200000 (2小时) request.timeout.ms=7206000 (~2小时)
这开始起作用了，在那之后，它是重新平衡的，我在消费者身上得到了这个错误。
浏览 3提问于2019-10-18得票数 4
3回答
我有一个弹簧启动应用程序与单一的kafka消费者，以获取一些主题的消息。但有时在处理消息时会发生错误。我希望像往常一样继续接收以下消息，同时能够不丢失该消息并接收它，例如，下次服务在修复后与使用者重启时。
有可能做到这一点吗？我知道我需要禁用自动提交并手动提交成功的消息，但是，在这种情况下，如果我没有对这个异常情况抛出任何异常，并手动提交下一个成功的消息，那么我将丢失前一个失败的消息，对吧？
浏览 0提问于2020-08-30得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
