总结/朱季谦 接触kafka开发已经两年多，也看过关于kafka的一些书，但一直没有怎么对它做总结，借着最近正好在看《Apache Kafka实战》一书，同时自己又搭建了三台kafka服务器，正好可以做一些总结记录。 本文主要是记录如何在kafka集群服务器上创建topic，查看topic列表 ...

环境 　　本文中的操作均基于kafka_1.3.3.0，且所有命令经过实际验证。 常用工具 新建Topic replication-factor： 指定副本数量 partitions：指定分区 删除Topic 查看所有Topic ...

kafka topic常用命令 创建topic 查看所有topic 查看topic的详细信息 查看所有topic 的详细信息 查看一个topic的详细信息 删除topic 如果只是运行命令删除topic，topic的数据并不会被删除 想要完全删除topic需要 ...

一、偏移量提交 消费者提交偏移量的主要是消费者往一个名为_consumer_offset的特殊主题发送消息，消息中包含每个分区的偏移量。 如果消费者一直运行，偏移量的提交并不会产生任何影响。但是如果有消费者发生崩溃，或者有新的消费者加入消费者群组的时候，会触发 Kafka 的再均衡。这使 ...

kafka针对每个消费组的消费信息都在zookeeper中做了记录，启动一个zookeeper客户端，以下可以看出kafka每个消费组在zookeeper中的消费每个kafka主题的信息 针对这个我们可以通过修改zookeeper中的信息来重置一个topic的消费组的offset ...

1. git 文档 https://github.com/progit/progit/blob/master/zh/02-git-basics/01-chapter2.markdo ...

目录： MetaData信息 Kafka偏移量 客户端负载均衡 MetaData信息 客户端如何知道该往哪个节点发送请求来获取数据：通过元数据。 元数据（MetaData）是什么：topic、topic的分区、每个分区有哪些副本、哪个副本是leader等信息。 一般 ...

group.id。所以需要手动修改偏移量到最新。 最后通过以下代码解决问题 　　 Propertie ...