小编Til*_*lak的帖子

我正在寻找安装融合模式注册表的选项，是否可以单独下载和安装注册表并使其与现有的 kafka 设置一起使用？

谢谢

我正在使用 spring kafka 2.7.8 来消费来自 kafka 的消息。消费者监听如下

@KafkaListener(topics = "topicName",
            groupId = "groupId",
            containerFactory = "kafkaListenerFactory")
    public void onMessage(ConsumerRecord record) {

   }

上面的 onMessage 方法一次接收一条消息。

这是否意味着 max.poll.records 被 spring 库设置为 1 或者它一次轮询 500 个（默认值）并且该方法一个接一个地接收。

提出这个问题的原因是，我们经常在产品中看到以下错误。在不到一分钟的时间内收到多个消费者的以下所有 4 个错误。试图了解这是由于间歇性的 kafka 代理连接问题还是由于负载。请指教。

Seek to current after exception; nested exception is org.apache.kafka.clients.consumer.CommitFailedException: Offset commit cannot be completed since the consumer is not part of an active group for auto partition assignment; it is likely that the consumer was kicked out of the group.

seek …

请帮助理解
1)选择Akka http vs Lagom构建微服务
2)REST API和基于Akka http/Lagom的微服务之间是否有任何区别.

谢谢