Add ValueError to transient kafka errors.

Author: tillahoffmann

testcontainers/kafka.py

@@ -35,7 +35,7 @@ def get_bootstrap_server(self):
         port = self.get_exposed_port(self.port_to_expose)
         return '{}:{}'.format(host, port)
 
-    @wait_container_is_ready(UnrecognizedBrokerVersion, NoBrokersAvailable, KafkaError)
+    @wait_container_is_ready(UnrecognizedBrokerVersion, NoBrokersAvailable, KafkaError, ValueError)
     def _connect(self):
         bootstrap_server = self.get_bootstrap_server()
         consumer = KafkaConsumer(group_id='test', bootstrap_servers=[bootstrap_server])