Hi, I'm running a two-node kafka cluster. When I (gracefully) shut down one of the kafka servers, the application that publishes message to the cluster keeps giving this error message:
org.apache.kafka.common.errors.TimeoutException: Batch containing 1 record(s) expired due to timeout while requesting metadata from brokers for <topic> In the kafka logs on the server that was not shut down, the following warning keeps appearing while the 2nd kafka server was not running: The client application is configured with both kafka servers as bootstrap nodes, so I was expecting that losing one server would not have any implications. WARN [ReplicaFetcherThread-0-1], Error in fetch kafka.server.ReplicaFetcherThread$FetchRequest@6fa01f39 (kafka.server.ReplicaFetcherThread) java.io.IOException: Connection to <stopped server>:9092 (id: 1 rack: null) failed I would not expect this warning, since the other server was gracefully shut down. But maybe this behaviour is normal? What could be the cause of this problem? Thanks, Tom
