from __future__ import absolute_import from kafka.partitioner.default import DefaultPartitioner, murmur2 __all__ = [ 'DefaultPartitioner', 'murmur2' ]