Skip to content

Commit

Permalink
docs
Browse files Browse the repository at this point in the history
Signed-off-by: Adam Kotwasinski <adam.kotwasinski@gmail.com>
  • Loading branch information
adamkotwasinski committed Nov 22, 2021
1 parent 4713ee7 commit bf42f6b
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 5 deletions.
2 changes: 0 additions & 2 deletions contrib/kafka/filters/network/source/protocol/generator.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,8 +5,8 @@ Kafka Broker filter

The Apache Kafka broker filter decodes the client protocol for
`Apache Kafka <https://kafka.apache.org/>`_, both the requests and responses in the payload.
The message versions in `Kafka 2.8.1 <http://kafka.apache.org/28/protocol.html#protocol_api_keys>`_
are supported.
Most of message versions present in
`Kafka 3.0.0 <http://kafka.apache.org/30/protocol.html#protocol_api_keys>`_ 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.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ Kafka Mesh filter
The Apache Kafka mesh filter provides a facade for `Apache Kafka <https://kafka.apache.org/>`_
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 <envoy_v3_api_msg_extensions.filters.network.kafka_mesh.v3alpha.KafkaMesh>`
* This filter should be configured with the name *envoy.filters.network.kafka_mesh*.
Expand Down

0 comments on commit bf42f6b

Please sign in to comment.