Skip to content

Changes

Summary

  1. hotfix: 针对备份及非备份采用不同的分区策略 (details)
Commit 34f447c39cbe480fa570bbc9dfb480a19010aa10 by linhancheng
hotfix: 针对备份及非备份采用不同的分区策略
The file was modified src/streaming-event-platform/flink-streaming-core/src/main/java/com/bcxin/flink/streaming/cores/utils/KafkaUtils.java
The file was modified src/kafka-connect/kafka-connect/src/main/java/com/bcxin/filters/RegionCodeFilter.java