Sarama ClusterAdmin连接问题-管道损坏
Sarama是一个用于与Apache Kafka集群进行交互的Go语言库。ClusterAdmin是Sarama库中的一个组件，用于管理Kafka集群的元数据信息。
在连接Sarama ClusterAdmin时，可能会遇到"管道损坏"的问题。这个问题通常是由于网络连接不稳定或者Kafka集群的配置问题引起的。
要解决这个问题，可以尝试以下几个步骤：
- 检查网络连接：确保你的网络连接是稳定的，没有任何中断或者延迟。可以尝试使用其他网络连接或者重启网络设备来解决问题。
- 检查Kafka集群配置：确保Kafka集群的配置正确无误。可以检查Kafka集群的IP地址、端口号、认证信息等配置项是否正确。
- 更新Sarama库版本：如果你正在使用较旧的Sarama库版本，尝试升级到最新版本，以确保你使用的是最新的修复和改进。
- 调整Sarama配置：可以尝试调整Sarama库的一些配置项，以适应你的环境。例如，可以增加连接超时时间、重试次数等。
总结起来，Sarama ClusterAdmin连接问题中的"管道损坏"可能是由于网络连接不稳定或者Kafka集群配置问题引起的。通过检查网络连接、Kafka集群配置，更新Sarama库版本以及调整Sarama配置，可以解决这个问题。
腾讯云提供了一系列与Kafka相关的产品和服务，例如TDMQ（消息队列）、CKafka（云原生消息队列）、CynosDB（云数据库）、云服务器等。你可以访问腾讯云官网了解更多关于这些产品的信息：https://cloud.tencent.com/product
相关·内容
我使用sarama(1.27) ClusterAdmin来管理kafka1.1.0中的主题。我管理kafka主题的应用程序是作为REST服务运行的。由于我的应用程序是作为服务运行的，我如何防止管道损坏的问题？我只在应用程序退出时关闭ClusterAdmin。使用相同的ClusterAdmin连接为所有请求提供服务。我为每个请求重新初始化clusterAdmin，如果出于任何原因它是空的(通常在第一次初始化后它不是空的，所以相同的<em
浏览 34提问于2020-09-04得票数 0
1回答
用例我不知道如何用我自己的方法“扩展”导出的结构。我试过这个： b, err := ca.findAnyBroker() // This is
浏览 0提问于2019-04-06得票数 0
回答已采纳
我知道java支持您创建主题，但是我在sarama中找不到任何关于如何创建主题的信息。如果可能的话，我应该使用哪个api的示例或说明将是非常感谢的。
浏览 5提问于2017-05-21得票数 10
回答已采纳
我正在使用github.com/Shopify/sarama包与Kafka进行交互。在我目前的方法中，我可以连接到代理并获得所有主题名称，而不存在任何问题(下面是“消费者代码”)。cluster, err := sarama.NewConsumer("localhost:9092", config) } else {
fmt.Printl
浏览 4提问于2020-03-24得票数 3
回答已采纳
1回答
验证失败zk会话超时问题
、、、、
我正在使用samuel的围棋管理员，并且遇到了“身份验证失败: zk:会话已被服务器”问题过期“。一旦遇到此问题，就会重试重新连接到动物园管理员，并获得成功连接。但问题是，它再次获得“身份验证失败”问题或未能注册消费者。而且，如果它确实成功地连接并进行了身份验证，使用者就不会以“当前注册的使用者:0”的形式使用该消息，除非我手动重新启动我的客户端，否则这个过程将继续。
这个问题和解决办法是什么？] 2016/05/15 04:52:
浏览 11提问于2016-05-16得票数 1
我读过很多类似的题目，但他们在这里不能回答我的问题。zookeeper: hostname: zookeeperproducer, err := sarama.NewSyncProducer([]string{"http://localhost:29092&qu
浏览 3提问于2020-03-12得票数 0
回答已采纳
我还正确地从OpenShift路由获取了引导服务器地址，但我似乎无法连接。编辑-忘记包含和提及它，但这就是我从Go Sarama代码中得到的错误。by unknown authority[Saramaexit status 1 因此，这看起来是一个证书问题，但我似乎遵循了正确的说明来获得证书。我的Kafka代理的名字是kafka，所以秘诀
浏览 20提问于2021-08-17得票数 1
回答已采纳
当订购者开始旋转时，他们似乎一开始就连接到代理，而代理日志则为testchainid (每个订单程序创建的一个虚拟通道)提供了创建新主题、分区等的内容。这是我的订单程序试图连接到代理时的日志转储：
2018-05-09 01:49:12.483 UTC [orderer/consensus/kafka] try -> DEBU 0f9 [channel] Validate -> DEBU 0fe ClientID is the default of 'sarama', you should
浏览 0提问于2018-05-09得票数 0
回答已采纳
启用了安全性，我创建了具有clusteradmin、useradmin等角色的用户，还有许多用户，他们的访问权限仅限于特定的数据库。但现在，当我试图收集存储引擎(在我们的例子中是有线老虎)统计数据时，我遇到了一个问题。为此，我需要直接连接到每个副本集中的单个mongodb节点，并发出db.serverStatus()命令。但是，拥有clusteradmin、useradmin等权限的所有用户的身份验证都失败了。如何直接对接(绕过mongos)集群内mongos节点并采集统计数据。
浏览 6提问于2017-12-06得票数 0
1回答
PHP和持久连接
、、
每当我打开到数据库的持久连接时，如果数据库守护进程崩溃，然后重新启动，则到该守护进程的新连接的30%将导致管道断开错误。
这可以通过更改持久连接句柄来修复，但需要手动完成。有没有一种解决方案，可以在不更换手柄的情况下修复损坏的管道错误？
浏览 3提问于2010-12-27得票数 0
回答已采纳
我是刚进入Golang的，我需要编写一个应用程序来向kafka发布事件，我找不到以下问题的答案：
可以在所有的应用程序中使用一个吗？
浏览 0提问于2019-02-01得票数 2
回答已采纳
我可以使用kubectl命令从我的PC连接到它，并运行kubectl命令，没有任何问题。然而，当我在Visual Studio 2019中通过Bridge-To-Kubernetes扩展进行连接时。另外，如何将Bridge- to -Kubernetes用户更改为默认使用clusteradmin用户而不是AAD用户？
浏览 14提问于2020-11-04得票数 0
Bellow是控制台日志：orderer0.example.com | [sarama] 2017/09/01] 2017/09/01 14:10:49.471350 config.go:329: Cl
浏览 5提问于2017-09-01得票数 2
1回答
我正在开发一个android视频上传应用程序，上传大量视频是一个问题，我有时会得到不同类型的异常(主机未解决，管道损坏)，我做了一个多部分的POST，但我有一种感觉，如果我一次上传一个字节块，将提高上传速度以及解决连接超时和这些类型的问题
浏览 0提问于2010-09-23得票数 0
以下代码在通过管道连接到T形三通时以断开的管道结尾，但在未通过管道连接时行为正常：Ctrl-C pressed.
浏览 0提问于2009-07-28得票数 2
回答已采纳
在azure管道模板中读取返回值'3q4w#V$X3q4w#V$X‘的变量yaml文件被损坏，成为值'3q4w#V#V’
- namebig_var_01，但是它的值已损坏，与上面的赋值不匹配
stages: jobs:参见的代码
如何使字符串变量big_var_01作为文字来处理，显然它是以某种方式被求值，从而损坏.
浏览 1提问于2021-07-28得票数 0
回答已采纳
1回答
我对Golang和Kafa并不熟悉，所以这似乎是个愚蠢的问题。 "fmt"
cluster "github.com/bsm/sarama-clusterconfig.Co
浏览 0提问于2018-12-07得票数 0
2.服务器需要一些时间来处理请求，通常超过60秒我在这个主题上发现了几个问题，但没有任何确凿的解决方案。服务器端错误日志: BlazeDSjava.io.IOException:管道断开写入失败:管道断开
下面是我的serives config.xml代码片段。
浏览 7提问于2015-02-09得票数 0
因此，我试图将Kafka用于我的应用程序，该应用程序有一个生产者将操作记录到Kafka MQ中，而使用者将它从我的应用程序在Go中的MQ.Since中读取出来，我正在使用Shopify Sarama来实现这一点用于消费者连接的当前代码：
master, err := sarama.NewConsumer([]string{brokerConnect},type %s with id : %d\n", msgContent.Type, msgContent.
浏览 0提问于2015-04-01得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
