log test again

Author: dapeng

kafka-base/kafka-base-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/CustomerFlinkPartition.java

@@ -3,13 +3,15 @@
 
 import org.apache.flink.streaming.connectors.kafka.partitioner.FlinkFixedPartitioner;
 
+import java.util.Arrays;
 import java.util.Random;
 import org.apache.flink.util.Preconditions;
 
 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);
         }