Kafa consumer消费消息时，向broker发出fetch请求去消费特定分区的消息，consumer指定消息在日志中的偏移量（offset），就可以消费从这个位置开始的消息，customer拥有了offset的控制权，可以向后回滚去重新消费之前的消息，这是很有意义的 ...

指定offset: 指定分区： 原文强参考：https://www.cnblogs.com/shouke/p/10463377.html ...

一、启动kafka 　　启动kafka之前一定要启动zookeeper，因为要使用kafka必须要使用zookeeper。 　　windows环境下启动，直接使用kafka自带的zookeeper： 　　E:\kafka_2.12-2.4.0\bin\windows ...

一次项目想，多线程消费主题的中的数据，百度了一波之后，可以按分区进行单独消费，记录一下 首先，传统按照主题消费： 按照主题分区消费： 参考：https://blog.csdn.net/russle/article/details/81258590 ...

启动zookeeper和Kafka之后，进入kafka目录（安装/启动kafka参考前面一章：https://www.cnblogs.com/cici20166/p/9425613.html） 1.创建Topic 　　1）运行命令： ./bin/kafka-topics.sh --create ...

启动zookeeper和Kafka之后，进入kafka目录（安装/启动kafka参考前面一章：https://www.cnblogs.com/cici20166/p/9425613.html） 1.创建Topic 　　1）运行命令： ./bin/kafka-topics.sh --create ...

SpringKafka消费指定的分区 我在这篇文章里记录一下配置kafkaListener消费指定分区的方法。 之前为了解决kafka消费过慢的问题，查了一些资料，找到一些解决办法，这里做一个总结和整理。 参考资料： 1、https://www.hangge.com/blog/cache ...

关于 Topic 和 Partition： 　　Topic： 在 kafka 中，topic 是一个存储消息的逻辑概念，可以认为是一个消息集合。每条消息发送到 kafka 集群的消息都有一个类别。物理上来说，不同的 topic 的消息是分开存储的，每个 topic 可以有多个生产者向它发送消息 ...