Errors in log from docker containers (kafka-axon-example)

[larsw]

Basic information

• Kafka Extension version: commit 7b59029

docker-compose -f kafka-axon-example/docker-compose.yaml up

Expected behaviour

A-OK

Actual behaviour

Loads of:

kafka-rest_1     | 2021-08-09T08:39:52.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: broker in state DOWN connecting
kafka-rest_1     | 2021-08-09T08:39:52.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 19
kafka-rest_1     | 2021-08-09T08:39:52.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Broker changed state DOWN -> CONNECT
kafka-rest_1     | 2021-08-09T08:39:52.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: Broadcasting state change
kafka-rest_1     | 2021-08-09T08:39:52.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: failed: err: Local: Broker transport failure: (errno: Connection refused)
kafka-rest_1     | 2021-08-09T08:39:52.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Connect to ipv4#127.0.0.1:9092 failed: Connection refused
kafka-rest_1     | 2021-08-09T08:39:52.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Broker changed state CONNECT -> DOWN
kafka-rest_1     | 2021-08-09T08:39:52.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: Broadcasting state change
kafka-rest_1     | 2021-08-09T08:39:52.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Purging bufq with 0 buffers
kafka-rest_1     | 2021-08-09T08:39:52.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Updating 0 buffers on connection reset
kafka-rest_1     | 2021-08-09T08:39:53.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: broker in state DOWN connecting
kafka-rest_1     | 2021-08-09T08:39:53.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 19
kafka-rest_1     | 2021-08-09T08:39:53.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Broker changed state DOWN -> CONNECT
kafka-rest_1     | 2021-08-09T08:39:53.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: Broadcasting state change
kafka-rest_1     | 2021-08-09T08:39:53.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: failed: err: Local: Broker transport failure: (errno: Connection refused)
kafka-rest_1     | 2021-08-09T08:39:53.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Connect to ipv4#127.0.0.1:9092 failed: Connection refused
kafka-rest_1     | 2021-08-09T08:39:53.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Broker changed state CONNECT -> DOWN
kafka-rest_1     | 2021-08-09T08:39:53.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: Broadcasting state change
kafka-rest_1     | 2021-08-09T08:39:53.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Purging bufq with 0 buffers
kafka-rest_1     | 2021-08-09T08:39:53.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Updating 0 buffers on connection reset
kafka-rest_1     | 2021-08-09T08:39:54.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: broker in state DOWN connecting
kafka-rest_1     | 2021-08-09T08:39:54.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 19
kafka-rest_1     | 2021-08-09T08:39:54.639Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Broker changed state DOWN -> CONNECT
kafka-rest_1     | 2021-08-09T08:39:54.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: Broadcasting state change
kafka-rest_1     | 2021-08-09T08:39:54.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: failed: err: Local: Broker transport failure: (errno: Connection refused)
kafka-rest_1     | 2021-08-09T08:39:54.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Connect to ipv4#127.0.0.1:9092 failed: Connection refused
kafka-rest_1     | 2021-08-09T08:39:54.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Broker changed state CONNECT -> DOWN
kafka-rest_1     | 2021-08-09T08:39:54.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: Broadcasting state change
kafka-rest_1     | 2021-08-09T08:39:54.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Purging bufq with 0 buffers
kafka-rest_1     | 2021-08-09T08:39:54.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Updating 0 buffers on connection reset
kafka-rest_1     | 2021-08-09T08:39:55.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: broker in state DOWN connecting
kafka-rest_1     | 2021-08-09T08:39:55.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 19
kafka-rest_1     | 2021-08-09T08:39:55.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Broker changed state DOWN -> CONNECT
kafka-rest_1     | 2021-08-09T08:39:55.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: Broadcasting state change
kafka-rest_1     | 2021-08-09T08:39:55.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: failed: err: Local: Broker transport failure: (errno: Connection refused)
kafka-rest_1     | 2021-08-09T08:39:55.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Connect to ipv4#127.0.0.1:9092 failed: Connection refused
kafka-rest_1     | 2021-08-09T08:39:55.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Broker changed state CONNECT -> DOWN
kafka-rest_1     | 2021-08-09T08:39:55.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: Broadcasting state change
kafka-rest_1     | 2021-08-09T08:39:55.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Purging bufq with 0 buffers
kafka-rest_1     | 2021-08-09T08:39:55.640Z sinek:nproducer:debug [thrd:localhost:9092/1]: localhost:9092/1: Updating 0 buffers on connection reset

[smcvb]

Thanks for filing this issue with us @larsw. We'll look into it.

If you are up for the task, any help to fix this would obviously be very much appreciated!
Please do not see it as a requirement, though. Help is great but not mandatory.

[lfgcampos]

It used to work in the past, no idea when/how it got broken.
Nevertheless, a fix is provided on 1dfa72f.

It was related to the KAFKA_ADVERTISED_LISTENERS property which was set as localhost where it should be using the container name.
For more info on the matter, I found this blog to be very useful: https://www.confluent.io/blog/kafka-listeners-explained/