Adjusting Runtime Scopes
Creating SSL Context with protocol: TLS
Opening producer on myexample.com:9093
Sending message to topic Kafka_Test
Creating SSL Context with protocol: TLS
Error: Error waiting for acknowledgement after sending message to topic Kafka_Test: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
============================================================================
| Exception:
============================================================================
| Message: Error waiting for acknowledgement after sending message to topic Kafka_Test: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
----------------------------------------------------------------------------
| Trapped Exception: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
| Trapped Message: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
----------------------------------------------------------------------------
STACK TRACE
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
at org.apache.kafka.clients.producer.KafkaProducer$FutureFailure.<init>(KafkaProducer.java:1150)
at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:846)
at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:784)
at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:671)
at com.itko.lisa.messaging.providers.kafka.asset.KafkaUtils.sendSingleMessage(KafkaUtils.java:349)
at com.itko.lisa.messaging.providers.kafka.operation.KafkaSendOperation.doExecute2(KafkaSendOperation.java:308)
at com.itko.lisa.messaging.providers.kafka.operation.KafkaSendOperation.doExecute2(KafkaSendOperation.java:48)
at com.itko.lisa.asset.operation.AbstractRetryableRuntimeOperation.doExecute(AbstractRetryableRuntimeOperation.java:30)
at com.itko.lisa.asset.operation.AbstractRuntimeOperation.execute(AbstractRuntimeOperation.java:168)
at com.itko.lisa.messaging.builder.AbstractSendReceiveOperation.doExecute(AbstractSendReceiveOperation.java:156)
at com.itko.lisa.asset.operation.AbstractRuntimeOperation.execute(AbstractRuntimeOperation.java:168)
at com.itko.lisa.asset.operation.AbstractOperationStep.execute(AbstractOperationStep.java:176)
at com.itko.lisa.asset.operation.AbstractOperationStep.execute(AbstractOperationStep.java:125)
at com.itko.lisa.asset.operation.AbstractOperationStepEditor$ExecuteTask.run(AbstractOperationStepEditor.java:577)
at com.itko.lisa.asset.ui.ProgressLog$Worker.doInBackground(ProgressLog.java:143)
at com.itko.lisa.asset.ui.ProgressLog$Worker.doInBackground(ProgressLog.java:101)
at javax.swing.SwingWorker$1.call(SwingWorker.java:295)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at javax.swing.SwingWorker.run(SwingWorker.java:334)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
============================================================================
at com.itko.lisa.messaging.providers.kafka.asset.KafkaUtils.sendSingleMessage(KafkaUtils.java:378)
at com.itko.lisa.messaging.providers.kafka.operation.KafkaSendOperation.doExecute2(KafkaSendOperation.java:308)
at com.itko.lisa.messaging.providers.kafka.operation.KafkaSendOperation.doExecute2(KafkaSendOperation.java:48)
at com.itko.lisa.asset.operation.AbstractRetryableRuntimeOperation.doExecute(AbstractRetryableRuntimeOperation.java:30)
at com.itko.lisa.asset.operation.AbstractRuntimeOperation.execute(AbstractRuntimeOperation.java:168)
at com.itko.lisa.messaging.builder.AbstractSendReceiveOperation.doExecute(AbstractSendReceiveOperation.java:156)
at com.itko.lisa.asset.operation.AbstractRuntimeOperation.execute(AbstractRuntimeOperation.java:168)
at com.itko.lisa.asset.operation.AbstractOperationStep.execute(AbstractOperationStep.java:176)
at com.itko.lisa.asset.operation.AbstractOperationStep.execute(AbstractOperationStep.java:125)
at com.itko.lisa.asset.operation.AbstractOperationStepEditor$ExecuteTask.run(AbstractOperationStepEditor.java:577)
at com.itko.lisa.asset.ui.ProgressLog$Worker.doInBackground(ProgressLog.java:143)
at com.itko.lisa.asset.ui.ProgressLog$Worker.doInBackground(ProgressLog.java:101)
at javax.swing.SwingWorker$1.call(SwingWorker.java:295)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at javax.swing.SwingWorker.run(SwingWorker.java:334)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
All supported DevTest releases.
Configuration/Environment issue.
We are able to successfully stage the Kafka test case when starting the Coordinator and Simulator as a server and specifying the Coordinator and Simulator names on the command line as well as the Registry.
See below examples:
C:\CA\DevTest\bin\Coordinator.exe -n ssl://<IP address>:2011/Coordinator -m ssl://<IP address>:2010/Registry
C:\CA\DevTest\\bin\Simulator.exe -n ssl://<IP address>:2014/Simulator -m ssl://<IP address>:2010/Registry
The problem was not being able to resolve the IP and DNS.