原因一： kafka 没有设置正确配置文件的时候 num.partition 设置是 1； 原因二： kafka 创建主题的时候没有创建一个分区以上的数量； ...

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 ...

如果觉得本文对您有帮助，不妨扫描下方微信二维码打赏点，您的鼓励是我前进最大的动力： ...

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

这是消费端的源码:https://github.com/xuebus/springkafkaconsumer 生产端的代码请求看另一篇博客:https://www.cnblogs.com/jun1019/p/7895746.html 该项目是使用的技术：SpringBoot ...

1. 前言 我们知道，生产者发送消息到主题，消费者订阅主题（以消费者组的名义订阅），而主题下是分区，消息是存储在分区中的，所以事实上生产者发送消息到分区，消费者则从分区读取消息，那么，这里问题来了，生产者将消息投递到哪个分区？消费者组中的消费者实例之间是怎么分配分区的呢？接下来，就围绕着 ...