Spring云流0x104567910

标签 spring apache-kafka spring-cloud-stream spring-cloud-stream-binder-kafka

我正在将 Spring Cloud Stream 与 Kafka 绑定(bind)器一起使用。我可以看到，应用程序启动后，它每分钟都会针对应用程序中配置的所有输入绑定(bind)抛出 INFO 级别日志。

application.properties中的配置

spring.cloud.function.definition=consumeMessage
spring.cloud.stream.bindings.consumeMessage-in-0.destination=Kafka-stream
spring.cloud.stream.bindings.consumeMessage-in-0.group=Kafka-stream-consumer-group

日志是-

2021-06-25 11:26:51.329  INFO 89511 --- [pool-3-thread-3] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-Kafka-stream-consumer-group-5, groupId=Kafka-stream-consumer-group] Found no committed offset for partition Kafka-stream-0

实际上，我认为这不应该发生，因为自动提交偏移量已启用

auto.commit.interval.ms = 5000
    auto.offset.reset = latest
    bootstrap.servers = [localhost:9092]
    check.crcs = true
    client.dns.lookup = default
    client.id = 
    client.rack = 
    connections.max.idle.ms = 540000
    default.api.timeout.ms = 60000
    enable.auto.commit = true
    exclude.internal.topics = true

我是否遗漏了配置中的某些内容？

最佳答案

看起来每次计算指标时我们都会得到这个日志。建议转移类(class)

org.apache.kafka.clients.consumer.internals.ConsumerCoordinator 到 WARN 级别

检查this线程进行更多讨论。 @garyrussell仅供引用

关于Spring云流0x104567910，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/68134619/