测试日志

Author: dapeng

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

@@ -9,6 +9,7 @@
 public class CustomerFlinkPartition<T> extends FlinkFixedPartitioner<T> {
     @Override
     public int partition(T record, byte[] key, byte[] value, String targetTopic, int[] partitions) {
+        System.out.println("key="+new String(key));
         Preconditions.checkArgument(partitions != null && partitions.length > 0, "Partitions of the target topic is empty.");
         if(key == null){
             Random random = new Random();

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

@@ -23,6 +23,7 @@ public CustomerKeyedSerializationSchema(SerializationMetricWrapper serialization
     }
 
     public byte[] serializeKey(Row element) {
+        System.out.println("element = " + element+"|partitionKeys=" + partitionKeys);
         if(partitionKeys == null || partitionKeys.length <=0){
             return null;
         }