def _get_conn(self, host, port):
host_key = (host, port)<EOL>if host_key not in self.conns:<EOL><INDENT>self.conns[host_key] = KafkaConnection(<EOL>host,<EOL>port,<EOL>timeout=self.timeout<EOL>)<EOL><DEDENT>return self.conns[host_key]<EOL>
Get or create a connection to a broker using host and port