out test

Author: dapeng

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

@@ -14,6 +14,8 @@ public int partition(T record, byte[] key, byte[] value, String targetTopic, int
         if(key == null){
             return super.partition(record, key, value, targetTopic, partitions);
         }
-        return partitions[key.hashCode() % partitions.length];
+        System.out.println("hashcode=" + key.hashCode());
+        Random random = new Random();
+        return partitions[random.nextInt() % partitions.length];
     }
 }

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

@@ -51,6 +51,7 @@ private byte[] serializeJsonKey(JsonRowSerializationSchema jsonRowSerializationS
                     sb.append(objectNode.get(key));
                 }
             }
+            System.out.println("serialKey=" + sb.toString());
             return sb.toString().getBytes();
         }catch (Exception e){