Source code for kafka.partitioner
from .roundrobin import RoundRobinPartitioner
from .hashed import HashedPartitioner
__all__ = [
'RoundRobinPartitioner', 'HashedPartitioner'
]
from .roundrobin import RoundRobinPartitioner
from .hashed import HashedPartitioner
__all__ = [
'RoundRobinPartitioner', 'HashedPartitioner'
]