diff --git a/drivers/output/kafka/config.go b/drivers/output/kafka/config.go index 9c0d1899..7e9e4712 100644 --- a/drivers/output/kafka/config.go +++ b/drivers/output/kafka/config.go @@ -21,7 +21,7 @@ type Config struct { Topic string `json:"topic" yaml:"topic" label:"Topic"` Address string `json:"address" yaml:"address" label:"请求地址"` Timeout int `json:"timeout" yaml:"timeout" label:"超时时间"` - Version string `json:"version" yaml:"version" label:"版本" default:"1.0.0.0" enum:"0.8.2.0, 0.8.2.1, 0.8.2.2, 0.9.0.0, 0.9.0.1, 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.1.1, 0.10.2.0, 0.10.2.1, 0.10.2.2, 0.11.0.0, 0.11.0.1, 0.11.0.2, 1.0.0.0, 1.0.1.0, 1.0.2.0, 1.1.0.0, 1.1.1.0, 2.0.0.0, 2.0.1.0, 2.1.0.0, 2.1.1.0, 2.2.0.0, 2.2.1.0, 2.2.2.0, 2.3.0.0, 2.3.1.0, 2.4.0.0, 2.4.1.0, 2.5.0.0, 2.5.1.0, 2.6.0.0, 2.6.1.0, 2.6.2.0, 2.7.0.0, 2.7.1.0, 2.8.0.0, 2.8.1.0, 3.0.0.0, 3.1.0.0"` + Version string `json:"kafka_version" yaml:"kafka_version" label:"版本" default:"1.0.0.0" enum:"0.8.2.0, 0.8.2.1, 0.8.2.2, 0.9.0.0, 0.9.0.1, 0.10.0.0, 0.10.0.1, 0.10.1.0, 0.10.1.1, 0.10.2.0, 0.10.2.1, 0.10.2.2, 0.11.0.0, 0.11.0.1, 0.11.0.2, 1.0.0.0, 1.0.1.0, 1.0.2.0, 1.1.0.0, 1.1.1.0, 2.0.0.0, 2.0.1.0, 2.1.0.0, 2.1.1.0, 2.2.0.0, 2.2.1.0, 2.2.2.0, 2.3.0.0, 2.3.1.0, 2.4.0.0, 2.4.1.0, 2.5.0.0, 2.5.1.0, 2.6.0.0, 2.6.1.0, 2.6.2.0, 2.7.0.0, 2.7.1.0, 2.8.0.0, 2.8.1.0, 3.0.0.0, 3.1.0.0"` PartitionType string `json:"partition_type" yaml:"partition_type" enum:"robin,hash,manual,random"` Partition int32 `json:"partition" yaml:"partition" switch:"partition_type==='manual'"` PartitionKey string `json:"partition_key" yaml:"partition_key" switch:"partition_type==='hash'"` diff --git a/go.mod b/go.mod index e69559fe..1cf1654b 100644 --- a/go.mod +++ b/go.mod @@ -7,7 +7,7 @@ require ( github.com/brianvoe/gofakeit/v6 v6.20.1 github.com/coocood/freecache v1.2.2 github.com/dubbogo/gost v1.13.1 - github.com/eolinker/eosc v0.12.4 + github.com/eolinker/eosc v0.12.5 github.com/fasthttp/websocket v1.5.0 github.com/fullstorydev/grpcurl v1.8.7 github.com/go-redis/redis/v8 v8.11.5 @@ -24,8 +24,8 @@ require ( github.com/soheilhy/cmux v0.1.5 github.com/urfave/cli/v2 v2.23.4 github.com/valyala/fasthttp v1.42.0 - golang.org/x/crypto v0.1.0 - golang.org/x/net v0.1.0 + golang.org/x/crypto v0.7.0 + golang.org/x/net v0.8.0 google.golang.org/grpc v1.50.1 google.golang.org/protobuf v1.28.1 ) @@ -114,7 +114,7 @@ require ( require ( dubbo.apache.org/dubbo-go/v3 v3.0.2-0.20220519062747-f6405fa79d5c - github.com/andybalholm/brotli v1.0.4 // indirect + github.com/andybalholm/brotli v1.0.5 // indirect github.com/apache/dubbo-go-hessian2 v1.11.6 github.com/armon/go-metrics v0.3.9 // indirect github.com/beorn7/perks v1.0.1 // indirect @@ -154,7 +154,7 @@ require ( github.com/jonboulle/clockwork v0.2.2 // indirect github.com/json-iterator/go v1.1.12 // indirect github.com/julienschmidt/httprouter v1.3.0 // indirect - github.com/klauspost/compress v1.15.9 // indirect + github.com/klauspost/compress v1.16.3 // indirect github.com/kr/fs v0.1.0 // indirect github.com/mattn/go-colorable v0.1.8 // indirect github.com/mattn/go-isatty v0.0.14 // indirect @@ -190,8 +190,8 @@ require ( go.uber.org/atomic v1.9.0 go.uber.org/multierr v1.6.0 // indirect go.uber.org/zap v1.23.0 - golang.org/x/sys v0.2.0 // indirect - golang.org/x/text v0.4.0 // indirect + golang.org/x/sys v0.6.0 // indirect + golang.org/x/text v0.8.0 // indirect golang.org/x/time v0.0.0-20220722155302-e5dcc9cfc0b9 // indirect google.golang.org/genproto v0.0.0-20211104193956-4c6863e31247 // indirect gopkg.in/sourcemap.v1 v1.0.5 // indirect