Spring Cloud Stream消费者没有阅读来自Kafka主题的消息

Question

我试图消费一个Kafka主题从Spring启动应用程序。我使用的是下面提到的版本的Spring云流

• Spring boot starter父级：2.5.7
• Spring云版本：2020.0.4

下面是代码和配置

application.yml

spring:
  zipkin:
    sender:
      type: kafka
  kafka:
    bootstrap-servers:
    - localhost:19091
  cloud:
    stream:
      bindings:
        audit-in-0:
          destination: com.tonitingaurav.kafka.log
          group: kafka-log-group
          consumer:
            concurrency: 10
            max-attempts: 3
      default-binder: kafka
      kafka:
        binder:
          brokers:
          - localhost:19091

消息消费者类

@Configuration
public class LogConsumer {

    @Bean
    Consumer<Log> audit(){
        return log -> {
            System.out.println(log.getMessage());
        };
    }
}

下面的消息发布者正在正确地发布消息。发布者是在不同的微服务中编写的。

@Component
public class LogEventPublisher {

    @Autowired
    @Qualifier(LogProducerKafkaConfig.KAFKA_LOG_PUBLISHER)
    MessageChannel messageChannel;

    public void logMessage(Log log) {
        Message<Log> message = MessageBuilder.withPayload(log).build();
        messageChannel.send(message);
    }

}

pom.xml

<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream-binder-kafka</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream-binder-kafka-streams</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream-test-support</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka-test</artifactId>
<scope>test</scope>
</dependency>

Answer 1

您已经在这里发布了一个非常类似的问题，并提供了两种不同解决方案的回复。此外，以下是您可以作为起点使用的示例：https://github.com/spring-cloud/spring-cloud-stream-samples