//pykafka
//pykafka/topic.py
//pykafka/broker.py
//pykafka/client.py
//pykafka/common.py
//pykafka/cluster.py
//pykafka/handlers.py
//pykafka/partition.py
//pykafka/connection.py
//pykafka/exceptions.py
//pykafka/cli
//pykafka/cli/__main__.py
//pykafka/cli/kafka_tools.py
//pykafka/partitioners.py
//pykafka/utils
//pykafka/utils/compat.py
//pykafka/utils/socket.py
//pykafka/utils/compression.py
//pykafka/utils/error_handlers.py
//pykafka/utils/struct_helpers.py
//pykafka/protocol
//pykafka/protocol/base.py
//pykafka/protocol/sasl.py
//pykafka/protocol/admin.py
//pykafka/protocol/fetch.py
//pykafka/protocol/offset.py
//pykafka/protocol/message.py
//pykafka/protocol/produce.py
//pykafka/protocol/__init__.py
//pykafka/protocol/metadata.py
//pykafka/protocol/offset_commit.py
//pykafka/protocol/group_membership.py
//pykafka/simpleconsumer.py
//pykafka/rdkafka
//pykafka/rdkafka/helpers.py
//pykafka/rdkafka/producer.py
//pykafka/rdkafka/_rd_kafkamodule.c
//pykafka/rdkafka/simple_consumer.py
//pykafka/balancedconsumer.py
//pykafka/membershipprotocol.py
//pykafka/sasl_authenticators.py
//pykafka/managedbalancedconsumer.py