1.背景

kafka环境页面上看着正常，如下

在控制台里发数据也正常，但是消费数据的时候如下

[root@1 bin]# ./kafka-console-consumer.sh --topic topic_lcc --zookeeper xxx:2181
{metadata.broker.list=xxx:19093, request.timeout.ms=30000, client.id=console-consumer-1552, security.protocol=PLAINTEXT

【Kafka】Kafka ERROR [ConsumerFetcherThread-console-consumer], Error for partition [xx,5] to broker 10相关推荐

【kafka】Kafka Fetch Session 剖析
1.概述转载:https://www.cnblogs.com/smartloli/p/14352489.html 1.概述最近有同学留言在使用Kafka的过程中遇到一些问题,比如在拉取的Topic ...
【Kafka】Kafka 使用 Twitter 的 Bijection 类库实现 avro 的序列化与反序列化
1.概述请参考:https://www.jianshu.com/p/a70950bab06d [Kafka]Kafka 使用传统的 avro API 自定义序列化类和反序列化类比较麻烦,需要根据 ...
【Kafka】kafka This may indicate that authentication failed due to invalid credentials
1.概述首先在搞这个问题的时候 [Kafka]Kafka inter.broker.listener.name must be a listener name defined in advertis ...
【Kafka】Kafka IllegalArgumentException: Could not find a ‘KafkaClient‘ entry in the JAAS configuratio
1.背景背景请参考:[Kafka]Kafka SCRAM认证 ERROR [ZooKeeperClient] Auth failed [lcc@lcc ~/soft/kafka/kafka_2.11 ...
【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】Kafka ERROR [ConsumerFetcherThread-console-consumer], Error for partition [xx,5] to broker 10

1.背景

【Kafka】Kafka ERROR [ConsumerFetcherThread-console-consumer], Error for partition [xx,5] to broker 10相关推荐

最新文章

热门文章