Package com.zendesk.maxwell.producer.partitioners

Class MaxwellKafkaPartitioner

java.lang.Object

com.zendesk.maxwell.producer.partitioners.AbstractMaxwellPartitioner

com.zendesk.maxwell.producer.partitioners.MaxwellKafkaPartitioner

public class MaxwellKafkaPartitioner
extends AbstractMaxwellPartitioner

Constructor Summary

Constructors

Constructor	Description
MaxwellKafkaPartitioner(String hashFunction, String partitionKey, String csvPartitionColumns, String partitionKeyFallback)

Method Summary

Modifier and Type	Method	Description
int	kafkaPartition(RowMap r, int numPartitions)

Methods inherited from class com.zendesk.maxwell.producer.partitioners.AbstractMaxwellPartitioner

getDatabase, getHashString, getHashString, getTable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MaxwellKafkaPartitioner

public MaxwellKafkaPartitioner(String hashFunction,
                               String partitionKey,
                               String csvPartitionColumns,
                               String partitionKeyFallback)

Method Detail

kafkaPartition

public int kafkaPartition(RowMap r,
                          int numPartitions)