问春云流消费者没有阅读卡夫卡主题的信息

EN

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);
    }

}

<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>