程序员经验分享-hwhale

无法从客户端会话 ID 读取附加数据

2023-12-21

我们有hadoop集群3 kafka机器和3 动物园管理员 servers

hadoop 版本 - 2.6.4 (HORTONWORKS)

在zookeeper日志下（/var/log/zookeeper）

我们看到了一百万条警告消息，例如：

2019-06-26 10:48:45,675 [myid:1] - WARN  [NIOServerCxn.Factory 0.000.0.0/0.0.0.0:2181:NIOServerCnxn@357] - caught end of stream exception
EndOfStreamException: Unable to read additional data from client sessionid 0x16b8e15a80ca681, likely client has closed socket
               at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
               at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208)
               at java.lang.Thread.run(Thread.java:745)

这些消息的含义是什么：

    caught end of stream exception EndOfStreamException
    Unable to read additional data from client sessionid

真正的问题是关于 kafka 机器。我们遇到了领导者不平衡的问题，Kafka主题分区最终得到了领导者-1


尝试让客户端重试。它解决了我的问题。不知何故，我将重试设置为零。

例如：hbase.client.retries.number

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

ApacheKafka

apachezookeeper

hdp

无法从客户端会话 ID 读取附加数据 的相关文章

  • Kafka中如何使用事务以及如何使用abortTransaction？

    我是 kafka 新手 我使用 Kafka Producer Java api 面对Kafka的这个问题 Kafka Invalid transition attempted from state COMMITTING TRANSACTIO

  • Grafana/prometheus 中没有 kafka 指标

    我成功部署了 Helm Chart普罗米修斯操作员 https github com coreos prometheus operator tree master helm prometheus operator kube 普罗米修斯 ht

  • 无法向 kafka 主题发送消息

    我正在使用 Kafka Play 以及 Scala 这是我的代码 我想在其中发送消息到kafka服务器 主题名称是 测试主题 尽管我没有在主题中看到我发送的消息 但我没有收到任何错误 这里有什么问题吗 import kafka produc

  • 如何使用 C# 从 Kafka 获取主题列表

    我想从卡夫卡获取主题列表 我正在使用 kafka net 客户端 但无法在有关获取主题列表的文档中找到 您可以使用 Confluence Kafka 包中提供的 AdminClient 列出所有主题 using Confluent Kafk

  • Kafka REST 代理 API 有哪些好处？

    我不知道Kafka REST Proxy API的优点 它是一个 REST API 所以我知道它对于管理来说很方便 人们为什么使用 Kafka REST 代理 API 添加对生产者或消费者的 Maven 依赖是否很麻烦 另外 我知道kafk

  • Strimzi 运算符 Kafka 集群 ACL 未启用类型：简单

    我们知道要启用Kafka ACL属性authorizer class name kafka security auth SimpleAclAuthorizer要添加到server properties但是如果 Kafka 集群由 Strim

  • kafka Avro 多个主题的消息反序列化器

    我正在尝试以 avro 格式反序列化 kafka 消息 我使用以下代码 https github com ivangfr springboot kafka debezium ksql blob master kafka research c

  • Kafka 主题删除不起作用

    我使用的是 Kafka 0 8 2 版本 在开发过程中 我想我可能需要删除一个主题 所以我所做的是将以下行放入服务器配置文件中并启动两个 kafka 服务器 delete topic enable true 当我需要删除一个主题并运行以下命

  • 断言 Kafka 发送有效

    我正在使用 Spring Boot 编写一个应用程序 因此要写信给 Kafka 我这样做 Autowired private KafkaTemplate

  • 在spark-kafka中使用schema将ConsumerRecord值转换为Dataframe

    我正在使用 Spark 2 0 2 和 Kafka 0 11 0 并且 我正在尝试在火花流中使用来自卡夫卡的消息 以下是代码 val topics notes val kafkaParams Map String Object bootst

  • 调试自定义 Kafka 连接器的简单有效的方法是什么？

    我正在使用几个 Kafka 连接器 在控制台输出中没有看到它们的创建 部署有任何错误 但是我没有得到我正在寻找的结果 没有任何结果 无论是期望的还是否则 我基于 Kafka 的示例 FileStream 连接器制作了这些连接器 因此我的调试

  • 2n + 1 法定人数是什么意思？

    我在描述 HBase 的 Zookeeper 配置时遇到过这个问题 但我对这个术语并不熟悉 N 与我的 HBase 集群中的节点数量有关系吗 或者我应该在 Zookeeper 集群中使用的节点数量 2f 1是指你所需要的可靠性 可用性水平

  • 使用表白名单选项更新 Debezium MySQL 连接器

    我正在使用 Debezium 0 7 5 MySQL 连接器 并且我试图了解如果我想使用以下选项更新此配置 最好的方法是什么table whitelist 假设我创建了一个连接器 如下所示 curl i X POST H Accept ap

  • 将数据从 Kafka 存储传输到 Kafka 主题

    我想在卡夫卡做这样的事情 继续将数据存储在 KStream Ktable Kafka store 中 当我的应用程序收到特定事件 数据时 仅将上述存储中的特定数据集发送到主题 我们可以在卡夫卡中做到这一点吗 我认为单独使用 Kafka 消费

  • 如何在 Python 中以编程方式检查 Kafka Broker 是否已启动并运行

    我正在尝试使用来自 Kafka 主题的消息 我正在使用包装器confluent kafka消费者 我需要在开始使用消息之前检查连接是否已建立 我读到消费者很懒 所以我需要执行一些操作才能建立连接 但我想检查连接建立而不执行consume o

  • Kafka Streams - 如何扩展 Kafka 存储生成的变更日志主题

    我有多个冗余应用程序实例 它们想要使用主题的所有事件并独立存储它们以进行磁盘查找 通过rocksdb 为了便于论证 我们假设这些冗余消费者正在服务无状态 http 请求 因此 负载不是使用 kafka 共享的 而是使用 kafka 将数据从

  • 从 Apache Kafka 中的主题删除消息

    所以我是 Apache Kafka 的新手 我正在尝试创建一个简单的应用程序 以便我可以更好地理解 API 我知道这个问题在这里被问了很多 但是如何清除存储在主题上的消息 记录 我看到的大多数答案都说要更改消息保留时间或删除并重新创建主题

  • 我的 Kafka 流应用程序刚刚退出，代码为 0，什么也不做

    为了尝试 Kafka 流 我这样做了 public static void main String args final StreamsBuilder builder new StreamsBuilder final Properties

  • 当我重新运行 Flink 消费者时，Kafka 再次消费最新消息

    我在用 Scala 编写的 Apache Flink API 中创建了一个 Kafka 消费者 每当我从某个主题传递一些消息时 它就会及时接收它们 但是 当我重新启动使用者时 它不会接收新的或未使用的消息 而是使用发送到该主题的最新消息 这

  • 卡夫卡流：RocksDB TTL

    据我了解 默认 TTL 设置为无穷大 非正数 但是 如果我们需要在存储中保留数据最多 2 天 我们可以使用 RocksDBConfigSetter 接口实现 即 options setWalTtlSeconds 172800 进行覆盖吗 或

随机推荐

  • Eclipse 编码 MacRoman -> UTF8

    我最近创建了一个项目 组织了它并且很好 我使用运行 Eclipse 的 Mac 不知怎的 它把所有的东西都存储在MacRoman中 该项目必须是 UTF8 有什么简单的方法来处理转换吗 你在这有一些详细的解释博客文章 http wiki w

  • 验证 Meteor AutoForm SimpleSchema 中的日期值

    我有以下架构 Dates attachSchema new SimpleSchema description type String label Description max 50 start type Date autoform afF

  • Django Rest框架全局分页参数不适用于ModelViewSet

    DRF 文档指出 仅当您使用通用视图或视图集时 才会自动执行分页 但我正在使用ModelViewSet它继承自ViewSet 所以我告诉自己 酷 我所要做的就是将其添加到我的settings py DEFAULT PAGINATION CL

  • WebSocket 中服务器重启时客户端重新连接

    我正在使用 PHP5 和 Chrome 浏览器作为客户端的 Web 套接字 我从网站上获取了代码http code google com p phpwebsocket http code google com p phpwebsocket

  • 算法复杂度 - 双星意味着什么

    有谁知道像这样的复杂性算法中的双星意味着什么O N 3 我在 PHP 中发现了一个相似文本 http php net manual en function similar text php功能并且不理解它 thx 表示功率 因此 n 3 表

  • 如何自定义SpringWebFlux WebClient JSON反序列化？

    我正在使用一个spring webflux WebClient https docs spring io spring docs 5 0 0 BUILD SNAPSHOT javadoc api org springframework we

  • 将儒略日期转换为公历日期

    我正在用 Lua 编写一个计算日落 日出的应用程序 为此 我必须首先将公历日期转换为儒略日 并从那里进行所有复杂的数学运算等 我已经完成了困难的数学计算 但现在我需要将儒略日期 例如 2456495 6833865 转换回公历日期 并附上时

  • 检索用户级别每个标签对应的答案总数

    我正在尝试创建一个查询 以查找与每个标签对应的答案总数 我在 stackoverflow 中给出 Through this https data stackexchange com stackoverflow query 7521 how

  • Scala：扩展内部类，不引用外部类

    我可以在外部类内部或从外部类派生的类内部扩展内部类 特征 我可以扩展外部类的特定实例的内部类 如下所示 class Outer class Inner class OtherCl val outer1 Outer class InnA ex

  • 绘制嵌套维恩图

    我的数据包含两个组的二进制指标 以及嵌套在前两组之一中的更多组的数据 例如 set seed 1 df lt data frame a rep 0 10 b rep 0 10 b 1 rep 0 10 b 2 rep 0 10 df a s

  • 如果参数改变，“arguments”对象也会改变

    我刚刚发现arguments如果参数之一发生变化 则对象实际上会发生变化 例如 function some a b c console log arguments args a b c a new Date console log argu

  • 使用Onload 还是准备好？

    在我的应用程序中我正在使用 document ready 这和有什么区别 document onload The ready http api jquery com ready 仅当DOM http en wikipedia org wik

  • 将路由从状态提供者转换为路由提供者

    我的 config JS 上有以下代码 它运行得很好 function config stateProvider urlRouterProvider ocLazyLoadProvider IdleProvider KeepaliveProv

  • 如何使用 ng-click 动态重新加载 ng-repeat 数据？

    我有一个页面包含ng repeat指示 这ng repeat页面首次加载时有效 但我希望能够使用ng click刷新内容ng repeat 我已经尝试过以下代码 但它不起作用 有什么建议么 div Load 1st set of items

  • SQL查询输出的逆序

    我有一个无法解决的问题 我使用 PHP 通过我的数据库运行以下命令 strQuery select from LastResult ORDER BY Date DESC LIMIT 10 结果一切正常 符合预期 但是 然后我必须将它们输入折

  • 清除 sqlalchemy 反射缓存

    我正在使用 sqlalchemy 的反射工具来获取 Table 对象 我这样做是因为这些表是动态的并且表 列可以更改 这是我正在使用的代码 def getTableByReflection self tableName metadata e

  • ipython 和 python 的输出差异

    据我了解 python 会打印repr的输出 但显然情况并非总是如此 例如 在 ipython 中 In 1 type Out 1 list In 2 set 3 1 2 Out 2 1 2 3 在Python中 gt gt gt type

  • 角度自定义下拉菜单

    How to create a custom dropdown in angular and load data

  • Java：使用 lambda 将行号添加到文件的优雅方法

    我习惯使用 lambda 逐行解析文件 比bufferedReader readLine 许久 但今天我遇到了一个问题 为每一行添加一个行号 它需要一个计数器 但 lambda 中的变量实际上应该是最终的 最后 我用 int 数组破解了它

  • 无法从客户端会话 ID 读取附加数据

    我们有hadoop集群3 kafka机器和3 动物园管理员 servers hadoop 版本 2 6 4 HORTONWORKS 在zookeeper日志下 var log zookeeper 我们看到了一百万条警告消息 例如 2019

热门标签