Skip to content

Changes

Summary

  1. 调整晋城的功能 (details)
  2. hotfix: 针对备份及非备份采用不同的分区策略 (details)
Commit 63694f47eed2fbd9c01d350b351a37343b514208 by linhancheng
调整晋城的功能
The file was modified src/kafka-connect/kafka-connect/src/main/java/com/bcxin/filters/RegionCodeFilter.java
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