This is an automated email from the ASF dual-hosted git repository.
xiaoyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shenyu.git
The following commit(s) were added to refs/heads/master by this push:
new 1ea62be0b Integration test docker compose file update for
logging-kafka (#3817)
1ea62be0b is described below
commit 1ea62be0be2f043b7e820278febe66d2b9365755
Author: qifanyyy <[email protected]>
AuthorDate: Mon Aug 8 09:35:43 2022 -0400
Integration test docker compose file update for logging-kafka (#3817)
* update docker compose and port from 8082 to 9092
* Integration test update docker compose
---
db/init/mysql/schema.sql | 6 +++---
db/init/oracle/schema.sql | 4 ++--
db/init/pg/create-table.sql | 4 ++--
db/upgrade/2.4.3-upgrade-2.5.0-mysql.sql | 4 ++--
db/upgrade/2.4.3-upgrade-2.5.0-pg.sql | 4 ++--
.../src/main/resources/sql-script/h2/schema.sql | 7 ++++---
.../shenyu-integrated-test-http/docker-compose.yml | 19 +++++++++++++++++++
.../shenyu-integrated-test-http/pom.xml | 8 ++++++++
.../plugin/logging/kafka/LoggingKafkaPluginTest.java | 2 +-
9 files changed, 43 insertions(+), 15 deletions(-)
diff --git a/db/init/mysql/schema.sql b/db/init/mysql/schema.sql
index b081d3cd4..b76000362 100644
--- a/db/init/mysql/schema.sql
+++ b/db/init/mysql/schema.sql
@@ -594,8 +594,8 @@ INSERT INTO `plugin` VALUES ('6', 'dubbo',
'{\"register\":\"zookeeper://localhos
INSERT INTO `plugin` VALUES ('8', 'springCloud', NULL, 'Proxy', 200, 0,
'2022-05-25 18:02:53', '2022-05-25 18:02:53');
INSERT INTO `plugin` VALUES ('9', 'hystrix', NULL, 'FaultTolerance', 130, 0,
'2022-05-25 18:02:53', '2022-05-25 18:02:53');
INSERT INTO `plugin` VALUES ('32',
'loggingElasticSearch','{\"host\":\"localhost\", \"port\": \"9200\"}',
'Logging', 190, 0, '2022-06-19 22:00:00', '2022-06-19 22:00:00');
-INSERT INTO `plugin` VALUES ('33', 'loggingKafka','{\"host\":\"localhost\",
\"port\": \"8082\"}', 'Logging', 180, 0, '2022-07-04 22:00:00', '2022-07-02
22:00:00');
-INSERT INTO `plugin` VALUES ('34', 'loggingAliyunSls','{\"projectName\":
\"shenyu\", \"logStoreName\": \"shenyu-logstore\", \"topic\":
\"shenyu-topic\"}', 'Logging', 175, 0, '2022-06-30 21:00:00', '2022-06-30
21:00:00');
+INSERT INTO `plugin` VALUES ('33', 'loggingKafka','{\"host\":\"localhost\",
\"port\": \"9092\"}', 'Logging', 180, 0, '2022-07-04 22:00:00', '2022-07-02
22:00:00');
+INSERT INTO `plugin` VALUES ('34', 'loggingAliyunSls','{\"projectName\":
\"shenyu\", \"logStoreName\": \"shenyu-logstore\, \"topic\":
\"shenyu-topic\"}', 'Logging', 175, 0, '2022-06-30 21:00:00', '2022-06-30
21:00:00');
-- ----------------------------
-- Table structure for plugin_handle
@@ -792,7 +792,7 @@ INSERT INTO `plugin_handle` VALUES ('1529402613204172882',
'32', 'index', 'index
INSERT INTO `plugin_handle` VALUES ('1529402613204172883', '32', 'sampleRate',
'sampleRate', 2, 1, 2,
'{\"required\":\"0\",\"defaultValue\":\"\",\"placeholder\":\"optional,0,0.01~1\"}',
'2022-06-19 22:00:00', '2022-06-19 22:00:00');
INSERT INTO `plugin_handle` VALUES ('1529402613204172884', '1',
'signRequestBody', 'signRequestBody', 3, 2, 9,
'{"required":"0","defaultValue":"false","placeholder":"signRequestBody","rule":""}',
'2022-06-29 10:08:02', '2022-06-29 10:08:02');
INSERT INTO `plugin_handle` VALUES ('1529402613204172885', '33', 'topic',
'topic', 2, 3, 1,
'{\"required\":\"1\",\"defaultValue\":\"shenyu-access-logging\"}', '2022-07-04
22:00:00', '2022-07-04 22:00:00');
-INSERT INTO `plugin_handle` VALUES ('1529402613204172886', '33',
'namesrvAddr', 'namesrvAddr', 2, 3, 2,
'{\"required\":\"1\",\"defaultValue\":\"localhost:8082\"}', '2022-07-04
22:00:00', '2022-07-04 22:00:00');
+INSERT INTO `plugin_handle` VALUES ('1529402613204172886', '33',
'namesrvAddr', 'namesrvAddr', 2, 3, 2,
'{\"required\":\"1\",\"defaultValue\":\"localhost:9092\"}', '2022-07-04
22:00:00', '2022-07-04 22:00:00');
INSERT INTO `plugin_handle` VALUES ('1529402613204172887', '33', 'sampleRate',
'sampleRate', 2, 3, 4,
'{\"required\":\"0\",\"defaultValue\":\"1\",\"placeholder\":\"optional,0,0.01~1\"}',
'2022-07-04 22:00:00', '2022-07-04 22:00:00');
INSERT INTO `plugin_handle` VALUES ('1529402613204172888', '33',
'maxResponseBody', 'maxResponseBody', 1, 3, 5,
'{\"required\":\"0\",\"defaultValue\":524288}', '2022-07-04 22:00:00',
'2022-07-04 22:00:00');
INSERT INTO `plugin_handle` VALUES ('1529402613204172889', '33',
'maxRequestBody', 'maxRequestBody', 1, 3, 6,
'{\"required\":\"0\",\"defaultValue\":524288}', '2022-07-04 22:00:00',
'2022-07-04 22:00:00');
diff --git a/db/init/oracle/schema.sql b/db/init/oracle/schema.sql
index c98f948c3..f6a61983a 100644
--- a/db/init/oracle/schema.sql
+++ b/db/init/oracle/schema.sql
@@ -852,7 +852,7 @@ INSERT /*+ IGNORE_ROW_ON_DUPKEY_INDEX(plugin(id)) */ INTO
plugin (id, name, role
INSERT /*+ IGNORE_ROW_ON_DUPKEY_INDEX(plugin(id)) */ INTO plugin (id, name,
config, role, sort, enabled) VALUES ('30', 'cache', '{"cacheType":"memory"}',
'Cache', 10, 0);
INSERT /*+ IGNORE_ROW_ON_DUPKEY_INDEX(plugin(id)) */ INTO plugin (id, name,
role, sort, enabled) VALUES ('31', 'mock', 'Mock', 1, 0);
INSERT /*+ IGNORE_ROW_ON_DUPKEY_INDEX(plugin(id)) */ INTO plugin (id, name,
config, role, sort, enabled) VALUES ('32', 'loggingElasticSearch',
'{"host":"localhost", "port": "9200"}', 'Logging', 190, 0);
-INSERT /*+ IGNORE_ROW_ON_DUPKEY_INDEX(plugin(id)) */ INTO plugin (id, name,
config, role, sort, enabled) VALUES ('33', 'loggingKafka',
'{"topic":"shenyu-access-logging", "namesrvAddr": "localhost:8082"}',
'Logging', 180, 0);
+INSERT /*+ IGNORE_ROW_ON_DUPKEY_INDEX(plugin(id)) */ INTO plugin (id, name,
config, role, sort, enabled) VALUES ('33', 'loggingKafka',
'{"topic":"shenyu-access-logging", "namesrvAddr": "localhost:9092"}',
'Logging', 180, 0);
INSERT /*+ IGNORE_ROW_ON_DUPKEY_INDEX(plugin(id)) */ INTO plugin (id, name,
config, role, sort, enabled) VALUES ('34', 'loggingAliyunSls', '{"projectName":
"shenyu", "logStoreName": "shenyu-logstore", "topic": "shenyu-topic"}',
'Logging', 175, '0');
@@ -1368,7 +1368,7 @@ insert /*+
IGNORE_ROW_ON_DUPKEY_INDEX(plugin_handle(plugin_id, field, type)) */
values ('1518229897214468177', '33', 'topic', 'topic', 2, 3, 1,
'{"required":"1","defaultValue":"shenyu-access-logging"}');
insert /*+ IGNORE_ROW_ON_DUPKEY_INDEX(plugin_handle(plugin_id, field, type))
*/ into plugin_handle (ID, PLUGIN_ID, FIELD, LABEL, DATA_TYPE, TYPE, SORT,
EXT_OBJ)
-values ('1518229897214468178', '33', 'namesrvAddr', 'namesrvAddr', 2, 3, 2,
'{"required":"1","defaultValue":"localhost:8082"}');
+values ('1518229897214468178', '33', 'namesrvAddr', 'namesrvAddr', 2, 3, 2,
'{"required":"1","defaultValue":"localhost:9092"}');
insert /*+ IGNORE_ROW_ON_DUPKEY_INDEX(plugin_handle(plugin_id, field, type))
*/ into plugin_handle (ID, PLUGIN_ID, FIELD, LABEL, DATA_TYPE, TYPE, SORT,
EXT_OBJ)
values ('1518229897214468179', '33', 'sampleRate', 'sampleRate', 2, 3, 4,
'{"required":"0","defaultValue":"1","placeholder":"optional,0,0.01~1"}');
diff --git a/db/init/pg/create-table.sql b/db/init/pg/create-table.sql
index b53883e7c..b4da15a1c 100644
--- a/db/init/pg/create-table.sql
+++ b/db/init/pg/create-table.sql
@@ -671,7 +671,7 @@ INSERT INTO "public"."plugin" VALUES ('29',
'loggingRocketMQ', '{"topic":"shenyu
INSERT INTO "public"."plugin" VALUES ('30', 'cache', '{"cacheType":"memory"}',
'Cache', 10, 0, '2022-05-25 18:08:01', '2022-05-25 18:08:01');
INSERT INTO "public"."plugin" VALUES ('31', 'mock', null, 'Mock', 1, 0,
'2022-06-16 14:40:35', '2022-06-16 14:40:55');
INSERT INTO "public"."plugin" VALUES ('32', 'loggingElasticSearch',
'{"host":"localhost", "port": "9200"}', 'Logging', 190, 0, '2022-06-19
22:00:00', '2022-06-19 22:00:00');
-INSERT INTO "public"."plugin" VALUES ('33', 'loggingKafka',
'{"topic":"shenyu-access-logging", "namesrvAddr": "localhost:8082"}',
'Logging', 180, 0, '2022-07-04 22:00:00', '2022-07-04 22:00:00');
+INSERT INTO "public"."plugin" VALUES ('33', 'loggingKafka',
'{"topic":"shenyu-access-logging", "namesrvAddr": "localhost:9092"}',
'Logging', 180, 0, '2022-07-04 22:00:00', '2022-07-04 22:00:00');
INSERT INTO "public"."plugin" VALUES ('34', 'loggingAliyunSls',
'{"projectName": "shenyu", "logStoreName": "shenyu-logstore", "topic":
"shenyu-topic"}', 'Logging', 175, 0, '2022-06-30 21:00:00', '2022-06-30
21:00:00');
-- ----------------------------
@@ -877,7 +877,7 @@ INSERT INTO "public"."plugin_handle" VALUES
('1529403902783524927', '32', 'index
INSERT INTO "public"."plugin_handle" VALUES ('1529403902783524928', '32',
'sampleRate', 'sampleRate', 2, 1, 2,
'{"required":"0","defaultValue":"","placeholder":"optional,0,0.01~1"}',
'2022-06-19 22:00:00', '2022-06-19 22:00:00');
INSERT INTO "public"."plugin_handle" VALUES ('1529403902783524929', '1',
'signRequestBody', 'signRequestBody', 3, 2, 9,
'{"required":"0","defaultValue":"false","placeholder":"signRequestBody","rule":""}',
'2022-06-29 10:08:02', '2022-06-29 10:08:02');
INSERT INTO "public"."plugin_handle" VALUES ('1529403902783524950', '33',
'topic', 'topic', 2, 3, 1,
'{"required":"1","defaultValue":"shenyu-access-logging"}', '2022-07-04
22:00:00', '2022-07-04 22:00:00');
-INSERT INTO "public"."plugin_handle" VALUES ('1529403902783524951', '33',
'namesrvAddr', 'namesrvAddr', 2, 3, 2,
'{"required":"1","defaultValue":"localhost:8082"}', '2022-07-04 22:00:00',
'2022-07-04 22:00:00');
+INSERT INTO "public"."plugin_handle" VALUES ('1529403902783524951', '33',
'namesrvAddr', 'namesrvAddr', 2, 3, 2,
'{"required":"1","defaultValue":"localhost:9092"}', '2022-07-04 22:00:00',
'2022-07-04 22:00:00');
INSERT INTO "public"."plugin_handle" VALUES ('1529403902783524952', '33',
'sampleRate', 'sampleRate', 2, 3, 4,
'{"required":"0","defaultValue":"1","placeholder":"optional,0,0.01~1"}',
'2022-07-04 22:00:00', '2022-07-04 22:00:00');
INSERT INTO "public"."plugin_handle" VALUES ('1529403902783524953', '33',
'maxResponseBody', 'maxResponseBody', 1, 3, 5,
'{"required":"0","defaultValue":524288}', '2022-07-04 22:00:00', '2022-07-04
22:00:00');
INSERT INTO "public"."plugin_handle" VALUES ('1529403902783524954', '33',
'maxRequestBody', 'maxRequestBody', 1, 3, 6,
'{"required":"0","defaultValue":524288}', '2022-07-04 22:00:00', '2022-07-04
22:00:00');
diff --git a/db/upgrade/2.4.3-upgrade-2.5.0-mysql.sql
b/db/upgrade/2.4.3-upgrade-2.5.0-mysql.sql
index 253c1fcde..1a6a89cf8 100644
--- a/db/upgrade/2.4.3-upgrade-2.5.0-mysql.sql
+++ b/db/upgrade/2.4.3-upgrade-2.5.0-mysql.sql
@@ -114,11 +114,11 @@ INSERT INTO `plugin_handle` VALUES
('1529402613204172905', '34', 'bufferQueueSiz
/* insert plugin for loggingElasticSearch */
-INSERT INTO `plugin` VALUES ('33', 'loggingKafka','{\"host\":\"localhost\",
\"port\": \"8082\"}', 'Logging', 180, 0, '2022-07-04 22:00:00', '2022-07-02
22:00:00');
+INSERT INTO `plugin` VALUES ('33', 'loggingKafka','{\"host\":\"localhost\",
\"port\": \"9092\"}', 'Logging', 180, 0, '2022-07-04 22:00:00', '2022-07-02
22:00:00');
/*insert plugin_handle data for plugin loggingKafka*/
INSERT INTO `plugin_handle` VALUES ('1529402613204172885', '33', 'topic',
'topic', 2, 3, 1,
'{\"required\":\"1\",\"defaultValue\":\"shenyu-access-logging\"}', '2022-07-04
22:00:00', '2022-07-04 22:00:00');
-INSERT INTO `plugin_handle` VALUES ('1529402613204172886', '33',
'namesrvAddr', 'namesrvAddr', 2, 3, 2,
'{\"required\":\"1\",\"defaultValue\":\"localhost:8082\"}', '2022-07-04
22:00:00', '2022-07-04 22:00:00');
+INSERT INTO `plugin_handle` VALUES ('1529402613204172886', '33',
'namesrvAddr', 'namesrvAddr', 2, 3, 2,
'{\"required\":\"1\",\"defaultValue\":\"localhost:9092\"}', '2022-07-04
22:00:00', '2022-07-04 22:00:00');
INSERT INTO `plugin_handle` VALUES ('1529402613204172887', '33', 'sampleRate',
'sampleRate', 2, 3, 4,
'{\"required\":\"0\",\"defaultValue\":\"1\",\"placeholder\":\"optional,0,0.01~1\"}',
'2022-07-04 22:00:00', '2022-07-04 22:00:00');
INSERT INTO `plugin_handle` VALUES ('1529402613204172888', '33',
'maxResponseBody', 'maxResponseBody', 1, 3, 5,
'{\"required\":\"0\",\"defaultValue\":524288}', '2022-07-04 22:00:00',
'2022-07-04 22:00:00');
INSERT INTO `plugin_handle` VALUES ('1529402613204172889', '33',
'maxRequestBody', 'maxRequestBody', 1, 3, 6,
'{\"required\":\"0\",\"defaultValue\":524288}', '2022-07-04 22:00:00',
'2022-07-04 22:00:00');
diff --git a/db/upgrade/2.4.3-upgrade-2.5.0-pg.sql
b/db/upgrade/2.4.3-upgrade-2.5.0-pg.sql
index ae48f5b42..4502456bb 100644
--- a/db/upgrade/2.4.3-upgrade-2.5.0-pg.sql
+++ b/db/upgrade/2.4.3-upgrade-2.5.0-pg.sql
@@ -123,11 +123,11 @@ INSERT INTO "public"."plugin_handle" VALUES
('1529403902783524970', '34', 'maxRe
INSERT INTO "public"."plugin_handle" VALUES ('1529403902783524971', '34',
'bufferQueueSize', 'bufferQueueSize', 1, 3, 13,
'{"required":"0","defaultValue":50000,"placeholder":""}', '2022-06-30
21:00:00', '2022-06-30 21:00:00');
/* insert plugin for loggingKafka */
-INSERT INTO "public"."plugin" VALUES ('33', 'loggingKafka',
'{"topic":"shenyu-access-logging", "namesrvAddr": "localhost:8082"}',
'Logging', 180, 0, '2022-07-04 22:00:00', '2022-07-04 22:00:00');
+INSERT INTO "public"."plugin" VALUES ('33', 'loggingKafka',
'{"topic":"shenyu-access-logging", "namesrvAddr": "localhost:9092"}',
'Logging', 180, 0, '2022-07-04 22:00:00', '2022-07-04 22:00:00');
/*insert plugin_handle data for plugin loggingKafka*/
INSERT INTO "public"."plugin_handle" VALUES ('1529403902783524950', '33',
'topic', 'topic', 2, 3, 1,
'{"required":"1","defaultValue":"shenyu-access-logging"}', '2022-07-04
22:00:00', '2022-07-04 22:00:00');
-INSERT INTO "public"."plugin_handle" VALUES ('1529403902783524951', '33',
'namesrvAddr', 'namesrvAddr', 2, 3, 2,
'{"required":"1","defaultValue":"localhost:8082"}', '2022-07-04 22:00:00',
'2022-07-04 22:00:00');
+INSERT INTO "public"."plugin_handle" VALUES ('1529403902783524951', '33',
'namesrvAddr', 'namesrvAddr', 2, 3, 2,
'{"required":"1","defaultValue":"localhost:9092"}', '2022-07-04 22:00:00',
'2022-07-04 22:00:00');
INSERT INTO "public"."plugin_handle" VALUES ('1529403902783524952', '33',
'sampleRate', 'sampleRate', 2, 3, 4,
'{"required":"0","defaultValue":"1","placeholder":"optional,0,0.01~1"}',
'2022-07-04 22:00:00', '2022-07-04 22:00:00');
INSERT INTO "public"."plugin_handle" VALUES ('1529403902783524953', '33',
'maxResponseBody', 'maxResponseBody', 1, 3, 5,
'{"required":"0","defaultValue":524288}', '2022-07-04 22:00:00', '2022-07-04
22:00:00');
INSERT INTO "public"."plugin_handle" VALUES ('1529403902783524954', '33',
'maxRequestBody', 'maxRequestBody', 1, 3, 6,
'{"required":"0","defaultValue":524288}', '2022-07-04 22:00:00', '2022-07-04
22:00:00');
diff --git a/shenyu-admin/src/main/resources/sql-script/h2/schema.sql
b/shenyu-admin/src/main/resources/sql-script/h2/schema.sql
index 3508c9365..9c65414d1 100755
--- a/shenyu-admin/src/main/resources/sql-script/h2/schema.sql
+++ b/shenyu-admin/src/main/resources/sql-script/h2/schema.sql
@@ -386,8 +386,9 @@ INSERT IGNORE INTO `plugin` (`id`, `name`, `role`, `sort`,
`config`, `enabled`)
INSERT IGNORE INTO `plugin` (`id`, `name`, `role`, `sort`, `config`,
`enabled`) VALUES ('29', 'loggingRocketMQ', 'Logging',
170,'{"topic":"shenyu-access-logging", "namesrvAddr":
"localhost:9876","producerGroup":"shenyu-plugin-logging-rocketmq"}', '0');
INSERT IGNORE INTO `plugin` (`id`, `name`, `config`, `role`, `sort`,
`enabled`) VALUES ('30', 'cache', '{"cacheType":"memory"}', 'Cache', 10, 0);
INSERT IGNORE INTO `plugin` (`id`, `name`, `config`, `role`, `sort`,
`enabled`) VALUES ('31', 'mock', null, 'Mock', 1, 0);
-INSERT IGNORE INTO `plugin` (`id`, `name`, `role`, `sort`, `config`,
`enabled`) VALUES ('32', 'loggingElasticSearch', 'Logging',
190,'{"host":"localhost", "port": "9200"}', '0');
-INSERT IGNORE INTO `plugin` (`id`, `name`, `role`, `sort`, `config`,
`enabled`) VALUES ('33', 'loggingKafka', 'Logging',
180,'{"topic":"shenyu-access-logging", "namesrvAddr": "localhost:8082"}', '0');
+INSER
+ T IGNORE INTO `plugin` (`id`, `name`, `role`, `sort`, `config`, `enabled`)
VALUES ('32', 'loggingElasticSearch', 'Logging', 190,'{"host":"localhost",
"port": "9200"}', '0');
+INSERT IGNORE INTO `plugin` (`id`, `name`, `role`, `sort`, `config`,
`enabled`) VALUES ('33', 'loggingKafka', 'Logging',
180,'{"topic":"shenyu-access-logging", "namesrvAddr": "localhost:9092"}', '0');
INSERT IGNORE INTO `plugin` (`id`, `name`, `role`, `sort`, `config`,
`enabled`) VALUES ('34', 'loggingAliyunSls', 'Logging', 175, '{"projectName":
"shenyu", "logStoreName": "shenyu-logstore", "topic": "shenyu-topic"}', '0');
@@ -565,7 +566,7 @@ INSERT IGNORE INTO plugin_handle (`id`,
`plugin_id`,`field`,`label`,`data_type`,
INSERT IGNORE INTO plugin_handle (`id`,
`plugin_id`,`field`,`label`,`data_type`,`type`,`sort`,`ext_obj`) VALUES
('1529402613204172883', '32', 'sampleRate', 'sampleRate', 2, 1, 2,
'{"required":"0","defaultValue":"","placeholder":"optional,0,0.01~1"}');
INSERT IGNORE INTO plugin_handle (`id`,
`plugin_id`,`field`,`label`,`data_type`,`type`,`sort`,`ext_obj`) VALUES
('1529402613204172884', '1', 'signRequestBody', 'signRequestBody', 3, 2, 9,
'{"required":"0","defaultValue":"false","placeholder":"signRequestBody","rule":""}');
INSERT IGNORE INTO plugin_handle (`id`,
`plugin_id`,`field`,`label`,`data_type`,`type`,`sort`,`ext_obj`) VALUES
('1529402613204172885', '33', 'topic', 'topic', 2, 3, 1,
'{"required":"1","defaultValue":"shenyu-access-logging"}');
-INSERT IGNORE INTO plugin_handle (`id`,
`plugin_id`,`field`,`label`,`data_type`,`type`,`sort`,`ext_obj`) VALUES
('1529402613204172886', '33', 'namesrvAddr', 'namesrvAddr', 2, 3, 2,
'{"required":"1","defaultValue":"localhost:8082"}');
+INSERT IGNORE INTO plugin_handle (`id`,
`plugin_id`,`field`,`label`,`data_type`,`type`,`sort`,`ext_obj`) VALUES
('1529402613204172886', '33', 'namesrvAddr', 'namesrvAddr', 2, 3, 2,
'{"required":"1","defaultValue":"localhost:9092"}');
INSERT IGNORE INTO plugin_handle (`id`,
`plugin_id`,`field`,`label`,`data_type`,`type`,`sort`,`ext_obj`) VALUES
('1529402613204172887', '33', 'sampleRate', 'sampleRate', 2, 3, 4,
'{"required":"0","defaultValue":"1","placeholder":"optional,0,0.01~1"}');
INSERT IGNORE INTO plugin_handle (`id`,
`plugin_id`,`field`,`label`,`data_type`,`type`,`sort`,`ext_obj`) VALUES
('1529402613204172888', '33', 'maxResponseBody', 'maxResponseBody', 1, 3, 5,
'{"required":"0","defaultValue":524288}');
INSERT IGNORE INTO plugin_handle (`id`,
`plugin_id`,`field`,`label`,`data_type`,`type`,`sort`,`ext_obj`) VALUES
('1529402613204172889', '33', 'maxRequestBody', 'maxRequestBody', 1, 3, 6,
'{"required":"0","defaultValue":524288}');
diff --git
a/shenyu-integrated-test/shenyu-integrated-test-http/docker-compose.yml
b/shenyu-integrated-test/shenyu-integrated-test-http/docker-compose.yml
index 8616dfb3a..d2636fb6c 100644
--- a/shenyu-integrated-test/shenyu-integrated-test-http/docker-compose.yml
+++ b/shenyu-integrated-test/shenyu-integrated-test-http/docker-compose.yml
@@ -128,6 +128,25 @@ services:
timeout: 2s
retries: 30
+
+ shenyu-kafka:
+ container_name: shenyu-kafka
+ image: confluentinc/cp-kafka:latest
+ restart: always
+ depends_on:
+ - shenyu-zk
+ networks:
+ - shenyu
+ ports:
+ - "9092:9092"
+ environment:
+ KAFKA_BROKER_ID: 1
+ KAFKA_ZOOKEEPER_CONNECT: shenyu-zk
+ KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9092
+ KAFKA_LISTENER_SECURITY_PROTOCOL_MAP:
PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
+ KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
+ KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
+
shenyu-rocketmq:
image: apache/rocketmq:4.9.3
container_name: shenyu-rocketmq
diff --git a/shenyu-integrated-test/shenyu-integrated-test-http/pom.xml
b/shenyu-integrated-test/shenyu-integrated-test-http/pom.xml
index 4e1cee2d6..e3503ab4c 100644
--- a/shenyu-integrated-test/shenyu-integrated-test-http/pom.xml
+++ b/shenyu-integrated-test/shenyu-integrated-test-http/pom.xml
@@ -186,6 +186,14 @@
</dependency>
<!--shenyu logging-rocketmq plugin end-->
+ <!--shenyu logging-kafka plugin start-->
+ <dependency>
+ <groupId>org.apache.shenyu</groupId>
+
<artifactId>shenyu-spring-boot-starter-plugin-logging-kafka</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <!--shenyu logging-kafka plugin end-->
+
<!--shenyu logging-elasticsearch plugin start-->
<dependency>
<groupId>org.apache.shenyu</groupId>
diff --git
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/test/java/org/apache/shenyu/plugin/logging/kafka/LoggingKafkaPluginTest.java
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/test/java/org/apache/shenyu/plugin/logging/kafka/LoggingKafkaPluginTest.java
index 64be53994..8c708202e 100644
---
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/test/java/org/apache/shenyu/plugin/logging/kafka/LoggingKafkaPluginTest.java
+++
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/test/java/org/apache/shenyu/plugin/logging/kafka/LoggingKafkaPluginTest.java
@@ -72,7 +72,7 @@ public final class LoggingKafkaPluginTest {
this.requestLog = new ShenyuRequestLog();
MockServerHttpRequest request = MockServerHttpRequest
.get("localhost")
- .remoteAddress(new InetSocketAddress(8090))
+ .remoteAddress(new InetSocketAddress(9092))
.header("X-source", "mock test")
.queryParam("queryParam", "Hello,World")
.build();
