This is an automated email from the ASF dual-hosted git repository.
chenwenkang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shenyu.git
from 0af754d949 [feat] sofa plugin config based on selector (#6062)
add dd57fb78da [feat]:loggingKafka plugin config based on selector (#6074)
No new revisions were added by this update.
Summary of changes:
db/init/mysql/schema.sql | 8 +-
db/init/ob/schema.sql | 8 +-
db/init/og/create-table.sql | 9 +-
db/init/oracle/schema.sql | 20 ++-
db/init/pg/create-table.sql | 9 +-
db/upgrade/2.7.0-upgrade-2.7.1-mysql.sql | 11 ++
db/upgrade/2.7.0-upgrade-2.7.1-ob.sql | 9 ++
db/upgrade/2.7.0-upgrade-2.7.1-og.sql | 9 ++
db/upgrade/2.7.0-upgrade-2.7.1-oracle.sql | 21 +++
db/upgrade/2.7.0-upgrade-2.7.1-pg.sql | 9 ++
.../src/main/resources/sql-script/h2/schema.sql | 9 +-
.../logging/kafka/cache/KafkaClientCache.java | 122 +++++++++++++++
.../logging/kafka/collector/KafkaLogCollector.java | 17 +++
.../kafka/config/KafkaLogCollectConfig.java | 163 +++++++++++++++++++++
.../handler/LoggingKafkaPluginDataHandler.java | 62 ++++++++
.../logging/kafka/cache/KafkaClientCacheTest.java | 67 +++++++++
.../kafka/collector/KafkaLogCollectorTest.java | 27 ++++
.../handler/LoggingKafkaPluginDataHandlerTest.java | 2 +-
18 files changed, 572 insertions(+), 10 deletions(-)
create mode 100644
shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/main/java/org/apache/shenyu/plugin/logging/kafka/cache/KafkaClientCache.java
create mode 100644
shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/test/java/org/apache/shenyu/plugin/logging/kafka/cache/KafkaClientCacheTest.java
