【问题标题】:Spring Kafka: Attempt to join group failed due to fatal error: The configured groupId is invalidSpring Kafka:由于致命错误,尝试加入组失败:配置的 groupId 无效
【发布时间】:2018-08-20 21:53:04
【问题描述】:

我目前正在编写一个 Kafka 侦听器,当我运行它时,它给了我很多这样的错误:

2018-03-12 14:55:17.866  INFO 19440 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=] (Re-)joining group
2018-03-12 14:55:17.866 ERROR 19440 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-2, groupId=] Attempt to join group failed due to fatal error: The configured groupId is invalid

这是因为没有正确设置消费者配置吗?

【问题讨论】:

    标签: spring apache-kafka listener consumer


    【解决方案1】:

    您缺少名为的属性:

    `spring.kafka.consumer.group-id=my-fancy-consumer-group-id`
    

    【讨论】:

    • 嗨,我也在考虑同样的事情。我使用 .yml 并且有 consumer: group-id: test 但它不起作用。
    • 怎么添加到yml?你可以添加一个例子吗?我认为 yml 配置有问题。
    • 谢谢,它有帮助,但为什么 @KafkaListener 中忽略了“组”属性,我们是否需要指定它?
    猜你喜欢
    • 2020-10-05
    • 1970-01-01
    • 2013-01-29
    • 1970-01-01
    • 2020-09-29
    • 1970-01-01
    • 2017-09-10
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多