CODEWITHSUNDEEP
javaspring-bootspring-cloud-streamspring-kafka
Devas
Devas

Reputation: 1694

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

I'm trying to run a custom Spring cloud Stream app starter, and getting the following INFO log,

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

My problem is my app doesn't work as intended (I can't connect to the websocket server, which this app will bring up) so I expect some clues from the kafka log. May be some missing dependency but I couldn't find one.

Is it an error? How can I debug this?

Upvotes: 2

Views: 6995

Answers (1)

Artem Bilan
Artem Bilan

Reputation: 121272

When you build Spring Boot Web application, you should keep in mind that security is switched on by default - HTTP Basic Authorization

The default user is, err, user.

The generate password you can find in logs. For example:

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

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

Although you can turn it off as well. For example command line arg:

--security.basic.enabled=false

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

Upvotes: 1

Related Questions