After migrate from v3 to v4 (4.5.1) kafka integration has stopped working with the same configuration (in the same server). We use kafka whithout TLS (tls=false). Now we have this error message:
2023-10-20T07:15:59.136446Z INFO chirpstack::integration::kafka: Initializing Kafka integration
2023-10-20T07:19:15.335435Z INFO chirpstack::integration::kafka: Publishing event topic= event_key=application.00000000-0000-0000-0000-000000000006.device.90dffb81872f8413.event.join
2023-10-20T07:19:21.142074Z ERROR chirpstack::integration::kafka: Publishing event error error=(KafkaError (Message production error: MessageTimedOut (Local: Message timed out)), OwnedMessage { payload: Some([123, 34, 100, 101, 100, 117, 112, 108, 105, 99, 97, 116, 105, 111, 110, 73, 100, 34, 58, 34, 48, 99, 49, 99, 100, 51, 97, 53, 45, 56, 101, 97, 102, 45, 52, 50, 53, 48, 45, 57, 98, 56, 51, 45, 48, 101, 99, 99, 102, 100, 54, 50, 52, 49, 98, 55, 34, 44, 34, 116, 105, 109, 101, 34, 58, 34, 50, 48, 50, 51, 45, 49, 48, 45, 50, 48, 84, 48, 55, 58, 49, 57, 58, 49, 52, 46, 55, 51, 51, 43, 48, 48, 58, 48, 48, 34, 44, 34, 100, 101, 118, 105, 99, 101, 73, 110, 102, 111, 34, 58, 123, 34, 116, 101, 110, 97, 110, 116, 73, 100, 34, 58, 34, 48, 48, 48, 48, 48, 48, 48, 48, 45, 48, 48, 48, 48, 45, 48, 48, 48, 48, 45, 48, 48, 48, 48, 45, 48, 48, 48, 48, 48, 48, 48, 48, 48, 48, 48, 49, 34, 44, 34, 116, 101, 110, 97, 110, 116, 78, 97, 109, 101, 34, 58, 34, 69, 85, 56, 54, 56, 34, 44, 34, 97, 112, 112, 108, 105, 99, 97, 116, 105, 111, 110, 73, 100, 34, 58, 34, 48, 48, 48, 48, 48, 48, 48, 48, 45, 48, 48, 48, 48, 45, 48, 48, 48, 48, 45, 48, 48, 48, 48, 45, 48, 48, 48, 48, 48, 48, 48, 48, 48, 48, 48, 54, 34, 44, 34, 97, 112, 112, 108, 105, 99, 97, 116, 105, 111, 110, 78, 97, 109, 101, 34, 58, 34, 100, 109, 45, 97, 105, 103, 117, 101, 115, 45, 118, 105, 99, 45, 112, 114, 101, 34, 44, 34, 100, 101, 118, 105, 99, 101, 80, 114, 111, 102, 105, 108, 101, 73, 100, 34, 58, 34, 52, 101, 102, 57, 97, 50, 53, 49, 45, 98, 100, 53, 101, 45, 52, 55, 97, 55, 45, 97, 56, 57, 54, 45, 102, 51, 97, 54, 97, 48, 50, 51, 98, 55, 48, 101, 34, 44, 34, 100, 101, 118, 105, 99, 101, 80, 114, 111, 102, 105, 108, 101, 78, 97, 109, 101, 34, 58, 34, 100, 105, 101, 104, 108, 45, 104, 114, 108, 45, 99, 45, 103, 51, 34, 44, 34, 100, 101, 118, 105, 99, 101, 78, 97, 109, 101, 34, 58, 34, 57, 48, 68, 70, 70, 66, 56, 49, 56, 55, 50, 70, 56, 52, 49, 51, 34, 44, 34, 100, 101, 118, 69, 117, 105, 34, 58, 34, 57, 48, 100, 102, 102, 98, 56, 49, 56, 55, 50, 102, 56, 52, 49, 51, 34, 44, 34, 100, 101, 118, 105, 99, 101, 67, 108, 97, 115, 115, 69, 110, 97, 98, 108, 101, 100, 34, 58, 34, 67, 76, 65, 83, 83, 95, 65, 34, 44, 34, 116, 97, 103, 115, 34, 58, 123, 125, 125, 44, 34, 100, 101, 118, 65, 100, 100, 114, 34, 58, 34, 48, 51, 52, 101, 102, 102, 48, 54, 34, 125]), key: Some([97, 112, 112, 108, 105, 99, 97, 116, 105, 111, 110, 46, 48, 48, 48, 48, 48, 48, 48, 48, 45, 48, 48, 48, 48, 45, 48, 48, 48, 48, 45, 48, 48, 48, 48, 45, 48, 48, 48, 48, 48, 48, 48, 48, 48, 48, 48, 54, 46, 100, 101, 118, 105, 99, 101, 46, 57, 48, 100, 102, 102, 98, 56, 49, 56, 55, 50, 102, 56, 52, 49, 51, 46, 101, 118, 101, 110, 116, 46, 106, 111, 105, 110]), topic: “”, timestamp: NotAvailable, partition: -1, offset: -1001, headers: Some(OwnedHeaders { ptr: 0x7f68c9210560 }) })
What am I doing wrong ?