更新时间:2025-05-26 GMT+08:00
        
          
          
        
      
      
      
      
      
      
      
      
  
      
      
      
        
使用Kafka
- 运行Kafka客户端获取Topic时报错
 - 安全集群中使用Python3.x对接Kafka
 - Flume正常连接Kafka后发送消息失败
 - Producer发送数据失败,报错“NullPointerException”
 - Producer发送数据失败,报错“TOPIC_AUTHORIZATION_FAILED”
 - Producer偶现发送数据失败,日志提示“Too many open files in system”
 - Consumer初始化成功但是无法从Kafka中获取指定Topic消息
 - Consumer消费数据失败,Consumer一直处于等待状态
 - SparkStreaming消费Kafka消息失败,提示“Error getting partition metadata”
 - 新建集群Consumer消费数据失败,提示“GROUP_COORDINATOR_NOT_AVAILABLE”
 - SparkStreaming消费Kafka消息失败,提示“Couldn't find leader offsets”
 - Consumer消费数据失败,提示“SchemaException: Error reading field”
 - Kafka Consumer消费数据丢失
 - 账号锁定导致启动Kafka组件失败
 - Kafka Broker上报进程异常,日志提示“IllegalArgumentException”
 - 执行Kafka Topic删除操作时发现无法删除
 - 执行Kafka Topic删除操作时提示“AdminOperationException”
 - 执行Kafka Topic创建操作时发现无法创建提示“NoAuthException”
 - 执行Kafka Topic设置ACL操作失败,提示“NoAuthException”
 - 执行Kafka Topic创建操作时发现无法创建提示“NoNode for /brokers/ids”
 - 执行Kafka Topic创建操作时发现无法创建提示“replication factor larger than available brokers”
 - Consumer消费数据时存在重复消费现象
 - 执行Kafka Topic创建操作时发现Partition的Leader显示为none
 - Kafka安全使用说明
 - 如何获取Kafka Consumer Offset信息
 - 如何针对Topic进行配置增加和删除
 - 如何读取“__consumer_offsets”内部topic的内容
 - 如何配置Kafka客户端shell命令日志
 - 如何获取Topic的分布信息
 - Kafka高可靠使用说明
 - 使用Kafka Shell命令无法操作Kafka集群
 - Kafka生产者写入单条记录过长问题
 - Kafka消费者读取单条记录过长问题
 - Kafka集群节点内多磁盘数据量占用高
 - Kafka连接ZooKeeper客户端时发生断链