OrcHome OrcHome
OrcHome个人中心.

℡点点滴滴__

已关注 关注

关注

暂无关注.....

粉丝

暂无粉丝.....


半兽人 回复 ℡点点滴滴__ kafka同一分区的消息的offset是否连续。 中:
你也新年好,你看下这篇文章中的,手动控制偏移量的代码片段。
先以文中的例子做测试,如果不行,贴代码出来。
http://orchome.com/451
7月前
℡点点滴滴__ 回复 半兽人 kafka同一分区的消息的offset是否连续。 中:
大哥,新年好!我是把enable.auto.commit设置false了的
7月前
半兽人 回复 ℡点点滴滴__ kafka同一分区的消息的offset是否连续。 中:
是不是自动提交开着呢。
7月前
℡点点滴滴__ 回复 半兽人 kafka同一分区的消息的offset是否连续。 中:
你好大哥,我还有个问题,就是我用kafka客户端消费时,我是手动提交偏移量的,把主题上的数据全部消费完,我重启客户端,让它再次消费,发现消费到上一次提交过offset的数据(起码我在代码里是提交offset了的),多试几次也是一样。这是咋回事呢?
7月前
半兽人 回复 ℡点点滴滴__ kafka同一分区的消息的offset是否连续。 中:
对应的。给你一篇文章,里面有详细介绍。
http://orchome.com/23

跟情况来指定是否连续,默认连续。
比如电话号码,是保留最新的电话,还是变更的整个过程都需要。看你的需求了。
7月前
℡点点滴滴__ 回复 半兽人 kafka同一分区的消息的offset是否连续。 中:
这个offset跟分区中的消息的位置position,对应的吗?position是连续的吗?日志清理时,会把相同key的消息做压缩清理,那消息的位置标号是不是就不连续了?
7月前
发表了 kafka同一分区的消息的offset是否连续。
7月前

半兽人 回复 ℡点点滴滴__ kafka同一分区的消息的offset是否连续。 评论:
你也新年好,你看下这篇文章中的,手动控制偏移量的代码片段。
先以文中的例子做测试,如果不行,贴代码出来。
http://orchome.com/451
7月前
℡点点滴滴__ 回复 半兽人 kafka同一分区的消息的offset是否连续。 评论:
大哥,新年好!我是把enable.auto.commit设置false了的
7月前
半兽人 回复 ℡点点滴滴__ kafka同一分区的消息的offset是否连续。 评论:
是不是自动提交开着呢。
7月前
℡点点滴滴__ 回复 半兽人 kafka同一分区的消息的offset是否连续。 评论:
你好大哥,我还有个问题,就是我用kafka客户端消费时,我是手动提交偏移量的,把主题上的数据全部消费完,我重启客户端,让它再次消费,发现消费到上一次提交过offset的数据(起码我在代码里是提交offset了的),多试几次也是一样。这是咋回事呢?
7月前
半兽人 回复 ℡点点滴滴__ kafka同一分区的消息的offset是否连续。 评论:
对应的。给你一篇文章,里面有详细介绍。
http://orchome.com/23

跟情况来指定是否连续,默认连续。
比如电话号码,是保留最新的电话,还是变更的整个过程都需要。看你的需求了。
7月前
℡点点滴滴__ 回复 半兽人 kafka同一分区的消息的offset是否连续。 评论:
这个offset跟分区中的消息的位置position,对应的吗?position是连续的吗?日志清理时,会把相同key的消息做压缩清理,那消息的位置标号是不是就不连续了?
7月前

℡点点滴滴__ 发表了 kafka同一分区的消息的offset是否连续。
7月前