From bf42f6b3800f89c958517fac7b367e0e13f5c792 Mon Sep 17 00:00:00 2001 From: Adam Kotwasinski Date: Fri, 19 Nov 2021 15:38:38 -0800 Subject: [PATCH] docs Signed-off-by: Adam Kotwasinski --- contrib/kafka/filters/network/source/protocol/generator.py | 2 -- .../listeners/network_filters/kafka_broker_filter.rst | 4 ++-- .../listeners/network_filters/kafka_mesh_filter.rst | 2 +- 3 files changed, 3 insertions(+), 5 deletions(-) diff --git a/contrib/kafka/filters/network/source/protocol/generator.py b/contrib/kafka/filters/network/source/protocol/generator.py index 8084e960702e..05ab8d059966 100755 --- a/contrib/kafka/filters/network/source/protocol/generator.py +++ b/contrib/kafka/filters/network/source/protocol/generator.py @@ -127,8 +127,6 @@ def parse_messages(self, input_files): # Windows support: see PR 10542 for details. amended = re.sub(r'-2147483648', 'INT32_MIN', without_empty_newlines) message_spec = json.loads(amended) - # Adopt publicly available messages only: - # https://kafka.apache.org/30/protocol.html#protocol_api_keys api_key = message_spec['apiKey'] if api_key <= 51 or api_key in [56, 57, 60, 61]: message = self.parse_top_level_element(message_spec) diff --git a/docs/root/configuration/listeners/network_filters/kafka_broker_filter.rst b/docs/root/configuration/listeners/network_filters/kafka_broker_filter.rst index ec7828db5c12..9a29a3bf73c2 100644 --- a/docs/root/configuration/listeners/network_filters/kafka_broker_filter.rst +++ b/docs/root/configuration/listeners/network_filters/kafka_broker_filter.rst @@ -5,8 +5,8 @@ Kafka Broker filter The Apache Kafka broker filter decodes the client protocol for `Apache Kafka `_, both the requests and responses in the payload. -The message versions in `Kafka 2.8.1 `_ -are supported. +Most of message versions present in +`Kafka 3.0.0 `_ are supported. The filter attempts not to influence the communication between client and brokers, so the messages that could not be decoded (due to Kafka client or broker running a newer version than supported by this filter) are forwarded as-is. diff --git a/docs/root/configuration/listeners/network_filters/kafka_mesh_filter.rst b/docs/root/configuration/listeners/network_filters/kafka_mesh_filter.rst index bebb7c31aa5b..2ad5bd2c2924 100644 --- a/docs/root/configuration/listeners/network_filters/kafka_mesh_filter.rst +++ b/docs/root/configuration/listeners/network_filters/kafka_mesh_filter.rst @@ -6,7 +6,7 @@ Kafka Mesh filter The Apache Kafka mesh filter provides a facade for `Apache Kafka `_ producers. Produce requests sent to this filter insance can be forwarded to one of multiple clusters, depending on configured forwarding rules. Corresponding message versions from -Kafka 2.8.1 are supported. +Kafka 3.0.0 are supported. * :ref:`v3 API reference ` * This filter should be configured with the name *envoy.filters.network.kafka_mesh*.