public Kafka sinkPartitionerCustom ( Class < ? extends FlinkKafkaPartitioner > partitionerClass ) { sinkPartitionerType = CONNECTOR_SINK_PARTITIONER_VALUE_CUSTOM ; sinkPartitionerClass = Preconditions . checkNotNull ( partitionerClass ) ; return this ; }
Configures how to partition records from Flink s partitions into Kafka s partitions .