log test again
@@ -3,6 +3,7 @@ package com.dtstack.flink.sql.sink.kafka;
import org.apache.flink.streaming.connectors.kafka.partitioner.FlinkFixedPartitioner;
+import java.util.Arrays;
import java.util.Random;
import org.apache.flink.util.Preconditions;
@@ -10,6 +11,7 @@ public class CustomerFlinkPartition<T> extends FlinkFixedPartitioner<T> {
@Override
public int partition(T record, byte[] key, byte[] value, String targetTopic, int[] partitions) {
Preconditions.checkArgument(partitions != null && partitions.length > 0, "Partitions of the target topic is empty.");
+ System.out.println("key = " + key+ ", value = " + value+ ", targetTopic = " + targetTopic + ", partitions = " + Arrays.toString(partitions));
if(key == null){
super.partition(record, key, value, targetTopic, partitions);
}
