Hi,
I am looking for POM Kafka integration and I look for Sample App.
I successfully deployed it and started.
I see it connected to POM and registered to events.

[2023-01-23 09:26:36,476] FINE [main] LoggerImpl.fine:56 - eventType 0 registered listener 1
[2023-01-23 09:26:36,781] FINE [main] LoggerImpl.fine:56 - Consumer started with {security.protocol=SSL, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=3, bootstrap.servers=192.168.0.108:9093, ssl.keystore.password=changeit, ssl.enabled.protocols=TLSv1.2, ssl.truststore.location=Z:\POMEventSDK\conf\pomTrustStore, ssl.truststore.password=changeit, ssl.keystore.location=Z:\POMEventSDK\conf\pomKeyStore, client.id=EVENT_SDK_CLIENT, key.deserializer=org.apache.kafka.common.serialization.StringDeserializer} on topic .*(POM_JOB)$
[2023-01-23 09:26:36,805] FINE [main] LoggerImpl.fine:56 - Receive message after client start
[2023-01-23 09:26:37,073] FINE [main] LoggerImpl.fine:56 - Discarding messages 0
[2023-01-23 09:26:37,073] FINE [main] LoggerImpl.fine:56 - Set Consumer to end offset
[2023-01-23 09:26:37,073] FINE [main] LoggerImpl.fine:56 - About to start JobEventConsumerThread

But next over some seconds I started to get a lot of errors like this:
This error is in Avaya libs and there is not way to troubleshot it.

[2023-01-23 16:55:39,197] ERROR [JobEventConsumerThread] LoggerImpl.error:81 - Error in JobEventConsumerThread
-----------------------------------------------------
java.lang.IllegalStateException: No entry found for connection 0
at org.apache.kafka.clients.ClusterConnectionStates.nodeState(ClusterConnectionStates.java:339)
at org.apache.kafka.clients.ClusterConnectionStates.disconnected(ClusterConnectionStates.java:143)
at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:926)
at org.apache.kafka.clients.NetworkClient.access$700(NetworkClient.java:67)
at org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:1090)
at org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:976)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:533)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:265)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:227)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:161)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.ensureFreshMetadata(ConsumerNetworkClient.java:175)
at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:337)
at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1226)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1195)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1135)
at com.avaya.pim.eventsdk.consumer.JobEventConsumerThread.run(JobEventConsumerThread.java:48)


Is there any ideas how to fix this?
Thank you.
Best regards, Dmitry