大佬,这个错误是什么问题呢?Offset commit failed on partition 23-0 at offset 0: The coordinator is not aware of this member.
情景是这样的,我是一个消费组对应着5个消费主题,其中一个消费主题因意外挂了,然后就报这个错了,但是我是了下其他四个消费主题还是可以用的;我想问的是一个消费组对应一个消费主题和一个消费组对应多个消费主题有啥区别呢?我这种情况,最好是用怎么样的呢?
大佬,这个错误是什么问题呢?Offset commit failed on partition 23-0 at offset 0: The coordinator is not aware of this member.
情景是这样的,我是一个消费组对应着5个消费主题,其中一个消费主题因意外挂了,然后就报这个错了,但是我是了下其他四个消费主题还是可以用的;我想问的是一个消费组对应一个消费主题和一个消费组对应多个消费主题有啥区别呢?我这种情况,最好是用怎么样的呢?
同样的异常:但是消费组里的Lag=0,不是消费者耗时导致了。
可能被其他成员消费掉了
消费者组名对一个topic,和对应多个topic没啥区别。
消费者组名是指topic的消息可以被同一个消费者组平分消息的标识,
另外,这个报错看样子消费者超过30秒(默认)没有提交offset,导致成员从消费者组中踢出,所以无法提交。
大佬,您的意思是kafka中一个消费组订阅一个消费主题,还是一个消费组订阅多个消费主题,是没有啥区别吗?
然后成员从消费组剔出,我再次消费的时候,这个踢出的消费者还是可以继续消费的,不影响业务吧?需要去解决吗
还有就是既然没区别,大佬,一个业务线(也就是一个消费主题)对应一个消费组,这个应该是比较好的吧?
技术底层是没啥区别的,业务层根据不同的消费场景取不同的名字即可。
可以继续消费,java版本成员踢出后,会重新加入进来,其他的客户端就不清楚了。
你要担心的是重复消费的问题,因为踢出后,消费的客户端并未提交offset,那么这些没提交的offset将会被其他消费者成员重复消费。
我是java的,我试了是会接下去继续消费主题
你的答案