AMQ Streams doesn't refresh DNS addresses

Solution Verified - Updated -

Issue

  • When recycling the AMQ Streams pods, the client applications maintains the IP address of the killed pods.
  • Client application tries to connect to the old IP address with the following WARN message in the logs:
WARN [Producer clientId=console-producer] Connection to node 0 (my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc.cluster.local/192.168.0.x:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
WARN [Consumer clientId=consumer-1, groupId=console-consumer-997] Connection to node 0 (my-cluster-kafka-0.my-cluster-kafka-brokers.myproject.svc.cluster.local/192.168.0.x:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

Environment

  • Red Hat AMQ Streams
    • 1.1.0

Subscriber exclusive content

A Red Hat subscription provides unlimited access to our knowledgebase, tools, and much more.

Current Customers and Partners

Log in for full access

Log In

New to Red Hat?

Learn more about Red Hat subscriptions

Using a Red Hat product through a public cloud?

How to access this content