1 2 3 4 5 6 7 8
from __future__ import absolute_import from kafka.partitioner.default import DefaultPartitioner, murmur2 __all__ = [ 'DefaultPartitioner', 'murmur2' ]