pykafka
pykafka copied to clipboard
Default port to 9092
If you initialize a KafkaClient without a port specifier in the hosts kwarg (eg KafkaClient(hosts="myhost.com")), you get a cryptic "list index out of range error". In these cases, KafkaClient should assume that the port is 9092 and attempt to connect.