You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@apisix.apache.org by st...@apache.org on 2022/09/29 06:24:34 UTC
[apisix] 01/01: fix: ci
This is an automated email from the ASF dual-hosted git repository.
starsz pushed a commit to branch feat_brokers
in repository https://gitbox.apache.org/repos/asf/apisix.git
commit da13f13bd7749ecd5e028866b74a995fd59e816c
Author: starsz <st...@gmail.com>
AuthorDate: Thu Sep 29 14:24:14 2022 +0800
fix: ci
---
apisix/plugins/kafka-logger.lua | 6 +++---
t/plugin/kafka-logger.t | 2 +-
t/plugin/kafka-logger2.t | 40 ++++++++++++++++++++--------------------
3 files changed, 24 insertions(+), 24 deletions(-)
diff --git a/apisix/plugins/kafka-logger.lua b/apisix/plugins/kafka-logger.lua
index f095bd870..ee079d02f 100644
--- a/apisix/plugins/kafka-logger.lua
+++ b/apisix/plugins/kafka-logger.lua
@@ -19,7 +19,6 @@ local log_util = require("apisix.utils.log-util")
local producer = require ("resty.kafka.producer")
local bp_manager_mod = require("apisix.utils.batch-processor-manager")
local plugin = require("apisix.plugin")
-local table = require("apisix.core.table")
local math = math
local pairs = pairs
@@ -223,10 +222,11 @@ function _M.log(conf, ctx)
end
-- reuse producer via lrucache to avoid unbalanced partitions of messages in kafka
- local broker_list = core.table.new(conf.broker_list and core.table.nkeys(conf.broker_list) or #conf.brokers, 0)
+ local length = conf.broker_list and core.table.nkeys(conf.broker_list) or #conf.brokers
+ local broker_list = core.table.new(length, 0)
local broker_config = {}
- if conf.broker_list then
+ if conf.broker_list then
for host, port in pairs(conf.broker_list) do
local broker = {
host = host,
diff --git a/t/plugin/kafka-logger.t b/t/plugin/kafka-logger.t
index 5b894abce..218f14c2a 100644
--- a/t/plugin/kafka-logger.t
+++ b/t/plugin/kafka-logger.t
@@ -72,7 +72,7 @@ done
}
}
--- response_body
-property "broker_list" is required
+value should match only one schema, but matches none
done
diff --git a/t/plugin/kafka-logger2.t b/t/plugin/kafka-logger2.t
index 60a584f1b..a77ca6eaa 100644
--- a/t/plugin/kafka-logger2.t
+++ b/t/plugin/kafka-logger2.t
@@ -342,47 +342,47 @@ qr/not found topic, retryable: true, topic: undefined_topic, partition_id: -1/
},
{
input = {
- brokers = {
- },
- kafka_topic = "test",
- key = "key1",
- },
+ brokers = {
+ },
+ kafka_topic = "test",
+ key = "key1",
+ },
},
{
input = {
- brokers = {
+ brokers = {
{
host = "127.0.0.1",
port = "9093",
},
- },
- kafka_topic = "test",
- key = "key1",
- },
+ },
+ kafka_topic = "test",
+ key = "key1",
+ },
},
{
input = {
- brokers = {
+ brokers = {
{
host = "127.0.0.1",
port = 0,
},
- },
- kafka_topic = "test",
- key = "key1",
- },
+ },
+ kafka_topic = "test",
+ key = "key1",
+ },
},
{
input = {
- brokers = {
+ brokers = {
{
host = "127.0.0.1",
port = 65536,
},
- },
- kafka_topic = "test",
- key = "key1",
- },
+ },
+ kafka_topic = "test",
+ key = "key1",
+ },
},
}