From 71d07615c0e733a5418e245e3fb8b7e117187834 Mon Sep 17 00:00:00 2001 From: Michal Budzyn Date: Thu, 25 Jul 2024 11:05:02 +0200 Subject: [PATCH] Support produce version 10, https://github.com/grepplabs/kafka-proxy/issues/171 --- Makefile | 2 +- README.md | 10 +++++----- proxy/processor_default.go | 2 +- 3 files changed, 7 insertions(+), 7 deletions(-) diff --git a/Makefile b/Makefile index 45122ba..dd40bbe 100644 --- a/Makefile +++ b/Makefile @@ -10,7 +10,7 @@ VERSION ?= $(shell git describe --tags --always --dirty) GOPKGS = $(shell go list ./... | grep -v /vendor/) BUILD_FLAGS ?= LDFLAGS ?= -X github.com/grepplabs/kafka-proxy/config.Version=$(VERSION) -w -s -TAG ?= "v0.3.10" +TAG ?= "v0.3.11" GOOS ?= $(if $(TARGETOS),$(TARGETOS),linux) GOARCH ?= $(if $(TARGETARCH),$(TARGETARCH),amd64) GOARM ?= $(TARGETVARIANT) diff --git a/README.md b/README.md index 2e75e1c..42207f0 100644 --- a/README.md +++ b/README.md @@ -39,7 +39,7 @@ As not every Kafka release adds new messages/versions which are relevant to the | | from 0.11.0 | | 0.2.9 | to 2.8.0 | | 0.3.1 | to 3.4.0 | -| 0.3.9 | to 3.7.0 | +| 0.3.11 | to 3.7.0 | ### Install binary release @@ -47,11 +47,11 @@ As not every Kafka release adds new messages/versions which are relevant to the Linux - curl -Ls https://github.com/grepplabs/kafka-proxy/releases/download/v0.3.10/kafka-proxy-v0.3.10-linux-amd64.tar.gz | tar xz + curl -Ls https://github.com/grepplabs/kafka-proxy/releases/download/v0.3.11/kafka-proxy-v0.3.11-linux-amd64.tar.gz | tar xz macOS - curl -Ls https://github.com/grepplabs/kafka-proxy/releases/download/v0.3.10/kafka-proxy-v0.3.10-darwin-amd64.tar.gz | tar xz + curl -Ls https://github.com/grepplabs/kafka-proxy/releases/download/v0.3.11/kafka-proxy-v0.3.11-darwin-amd64.tar.gz | tar xz 2. Move the binary in to your PATH. @@ -69,7 +69,7 @@ Docker images are available on [Docker Hub](https://hub.docker.com/r/grepplabs/k You can launch a kafka-proxy container for trying it out with - docker run --rm -p 30001-30003:30001-30003 grepplabs/kafka-proxy:0.3.8 \ + docker run --rm -p 30001-30003:30001-30003 grepplabs/kafka-proxy:0.3.11 \ server \ --bootstrap-server-mapping "localhost:19092,0.0.0.0:30001" \ --bootstrap-server-mapping "localhost:29092,0.0.0.0:30002" \ @@ -88,7 +88,7 @@ Docker images with precompiled plugins located in `/opt/kafka-proxy/bin/` are ta You can launch a kafka-proxy container with auth-ldap plugin for trying it out with - docker run --rm -p 30001-30003:30001-30003 grepplabs/kafka-proxy:0.3.8-all \ + docker run --rm -p 30001-30003:30001-30003 grepplabs/kafka-proxy:0.3.11-all \ server \ --bootstrap-server-mapping "localhost:19092,0.0.0.0:30001" \ --bootstrap-server-mapping "localhost:29092,0.0.0.0:30002" \ diff --git a/proxy/processor_default.go b/proxy/processor_default.go index 8fe12d9..291073a 100644 --- a/proxy/processor_default.go +++ b/proxy/processor_default.go @@ -159,7 +159,7 @@ func (handler *DefaultRequestHandler) mustReply(requestKeyVersion *protocol.Requ return false, nil, err } - case 3, 4, 5, 6, 7, 8, 9: + case 3, 4, 5, 6, 7, 8, 9, 10: // CorrelationID + ClientID if err = acksReader.ReadAndDiscardHeaderV1Part(reader); err != nil { return false, nil, err