KafkaProducer 在应用程序启动时停止，说 "Closing the Kafka producer with timeoutMillis = 30000 ms"

Question

我正在尝试运行自定义 Spring 云流应用启动程序，并获取以下信息日志，

2017-11-14 14:59:24.600  INFO 30300 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka version : 0.10.1.1
2017-11-14 14:59:24.600  INFO 30300 --- [           main] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId : f10ef2720b03b247
2017-11-14 14:59:24.747  INFO 30300 --- [           main] o.a.k.clients.producer.KafkaProducer     : Closing the Kafka producer with timeoutMillis = 30000 ms.
2017-11-14 14:59:24.768  INFO 30300 --- [           main] o.s.integration.channel.DirectChannel    : Channel 'websocket-source.output' has 1 subscriber(s).
2017-11-14 14:59:24.773  INFO 30300 --- [           main] o.s.c.support.DefaultLifecycleProcessor  : Starting beans in phase 0
2017-11-14 14:59:24.906  INFO 30300 --- [           main] o.s.i.endpoint.EventDrivenConsumer       : Adding {logging-channel-adapter:_org.springframework.integration.errorLogger} as a subscriber to the 'errorChannel' channel

我的问题是我的应用程序没有按预期工作（我无法连接到该应用程序将启动的 websocket 服务器）所以我希望从 kafka 日志中获得一些线索。可能缺少一些依赖项，但我找不到。

这是一个错误吗？我该如何调试？

Answer 1

构建 Spring Boot Web 应用程序时，请记住默认情况下安全性已打开 - HTTP 基本授权

默认用户是，呃，user。

您可以在日志中找到的生成密码。例如：

2017-11-14 11:56:09.756  INFO 7304 --- [           main] b.a.s.AuthenticationManagerConfiguration :

Using default security password: 396c8870-f36e-44a5-aaea-735d5a8e950a

尽管您也可以将其关闭。例如命令行参数：

--security.basic.enabled=false

https://docs.spring.io/spring-boot/docs/1.5.8.RELEASE/reference/htmlsingle/#howto-switch-off-spring-boot-security-configuration

KafkaProducer 在应用程序启动时停止，说 "Closing the Kafka producer with timeoutMillis = 30000 ms"

KafkaProducer stops on application startup, saying "Closing the Kafka producer with timeoutMillis = 30000 ms"

java

spring-boot

spring-cloud-stream

spring-kafka