【Kafka】nable to write to standard out, closing consumer Console consumer process hangs on SIGINT
1.背景
这是一个bug原文：https://issues.apache.org/jira/browse/KAFKA-3501
有时，当在管道中运行“ kafka-console-consumer”脚本并尝试使用“ SIGINT”（“ ctrl + c”）将其停止时，该过程不会停止。
ubuntu@xxx:~$ kafka-console-consumer --zookeeper localhost --topic topic --from-beginning | grep "pattern"
record1
...
recordN
【Kafka】nable to write to standard out, closing consumer Console consumer process hangs on SIGINT相关推荐
- 【kafka】Kafka 幂等 Producer
1.概述 [Kafka]Kafka幂等性原理及实现剖析 [kafka]Kafka 事务性之幂等性实现 官网:Idempotent Producer 2.简介 Kafka提供了"至少一次&qu ...
- 【Kafka】Kafka 如果 动态 不停止的情况下 修改 消费组 offset
文章目录 1.概述 2.方案1 3.方案2 1.概述 测试点:有人遇到这样的情况,他一个消费者正在消费一个环境的topic,然后他想启动另外一个消费组,但是是使用了同一个消费组,这个去更改 消费组of ...
- 【kafka】kafka获取消费组异常 EOFException: null KeeperErrorCode
文章目录 1.场景1 1.1 概述 1.2 源码解析 1.2.1 sendRequest 1.2.2 receive 1.2.3 readCompletely 1.2 4 readFromReadab ...
- 【kafka】kafka kerberos Cannot locate KDC Unable to locate KDC for realm
文章目录 1.概述 2.场景2 1.概述 本次是在 [kafka]kafka 消费 带有 kerberos认证的服务器 这个都搞通的情况下,搞这个. 机器的环境如下 12.12.12.24 kdc服务 ...
- 【kafka】kafka kerberos KeeperErrorCode = InvalidACL for /config/topics
文章目录 1.概述 1.概述 环境搭建参考:[kafka]kafka 消费 带有 kerberos认证的服务器 在这个kerberos认证的环境下,我想测试一下,构建zk的客户端是否需要认证,然后代码 ...
- 【kafka】Replication factor: 1 larger than available brokers:0
文章目录 1.概述 1.概述 文章重复了:[Kafka]kafka replication factor : 3 larger than avaiable brokers:2 kafka现在一创建消费 ...
- 【kafka】kerberos Server not found in Kerberos database LOOKING_UP_SERVER Identifier doesn‘t match
文章目录 1.概述 2.配置如下 3.测试 1.概述 首先参考kafka的配置环境:[kafka]kerberos认证下 kafka 报错Bootstrap broker host:ip (id: - ...
- 【kafka】kerberos client is being asked for a password not available to garner authentication informa
文章目录 1.场景1 1.1 概述 1.2.具体测试 2.场景2 3.1 概述 3.2 解决 1.场景1 关联文章: [zookeeper]zookeeper的ACL权限控制 1.1 概述 首先参考k ...
- 【kafka】Unexpected handshake request with client mechanism GSSAPI, enabled mechanisms are
文章目录 1.概述 1.概述 首先参考kafka的配置环境:[kafka]kerberos认证下 kafka 报错Bootstrap broker host:ip (id: -1 rack: null ...
最新文章
- yolov3为什么对大目标检测不好_基于改进Yolov3的目标检测的研究
- soc 设计soc设计 uml实务手册_采用 USB4 技术升级 SoC 设计
- 为什么我不建议你买保险？
- 【DP】方格计数（nowcoder 20107-B）
- 基础知识(十四)服务器搭建
- 恩墨学院丨OBCP墨天轮精品课正式上线啦~
- oracle创建用户和密码以及授权登录问题
- android简单小游戏开发工具,傻瓜化开发Android小游戏
- 对Java回调函数的理解
- time模块时间格式转换及faker库数据伪造
- 系统学习Spring之Spring in action(三)
- mysql force index 语法_MySQL FORCE INDEX 强制索引使用
- 怎么在图片中添加表格？
- get-element-by-id转换为getElementById
- MIMIC数据库基本信息分析
- vue中的路由守卫(导航守卫)
- corenlp分词 stanford_Stanford CoreNLP 入门指南
- rust休闲玩家_《Rust》坚持强制限定角色性别 玩家怒喷开发商傻蛋
- 有以下三张表，学生表 student 课程表 course 成绩表 result
- AIR2.0 打开exe