From bee22b368a90c830404b5ea56bb298f7d3beaa4b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Geir=20Ove=20Gr=C3=B8nmo?= Date: Thu, 11 Dec 2025 10:02:30 +0100 Subject: [PATCH] IS-18610: Removed references to key_schema and value_schema properties --- .../service-configuration/pipes/configuration-sinks-kafka.rst | 2 +- .../service-configuration/pipes/configuration-sources-kafka.rst | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/hub/documentation/service-configuration/pipes/configuration-sinks-kafka.rst b/hub/documentation/service-configuration/pipes/configuration-sinks-kafka.rst index 49e194bd4e..9aa09c7798 100644 --- a/hub/documentation/service-configuration/pipes/configuration-sinks-kafka.rst +++ b/hub/documentation/service-configuration/pipes/configuration-sinks-kafka.rst @@ -5,7 +5,7 @@ Kafka sink The Kafka sink produces data to a Kafka topic. -Entities sent to this sink will use the ``"key"``, ``"value"``, ``"headers"``, ``"key_schema"`` and ``"value_schema"`` properties to produce the messages sent to the Kafka topic. The latter two properties are only relevant if the ``"confluent_schema_json"`` serializer is used. The properties ``"key"`` and ``"value"`` are mandatory. The ``"headers"`` property is optional, but it must be an object with string keys and string or bytes values if present. +Entities sent to this sink will use the ``"key"``, ``"value"`` and ``"headers"`` properties to produce the messages sent to the Kafka topic. The latter two properties are only relevant if the ``"confluent_schema_json"`` serializer is used. The properties ``"key"`` and ``"value"`` are mandatory. The ``"headers"`` property is optional, but it must be an object with string keys and string or bytes values if present. The properties used matches the properties emitted by the :ref:`Kafka source `. This means that it should be possible to consume a topic and produce to a new topic in a pipe with no DTL. diff --git a/hub/documentation/service-configuration/pipes/configuration-sources-kafka.rst b/hub/documentation/service-configuration/pipes/configuration-sources-kafka.rst index c5d17ba676..009f92178d 100644 --- a/hub/documentation/service-configuration/pipes/configuration-sources-kafka.rst +++ b/hub/documentation/service-configuration/pipes/configuration-sources-kafka.rst @@ -5,7 +5,7 @@ Kafka source The Kafka source consumes data from a Kafka topic. The consumer does not use a consumer group, but instead stores the offset in the pipe, and it does not commit the consumer offset back to Kafka. -The entities emitted from this source has the properties ``"offset"``, ``"partition"``, ``"timestamp"``, ``"key"``, ``"key_schema"``, ``"value"``, ``"value_schema"``, ``"headers"``. If key deserialization fails and ``"strict"`` is ``false`` then the entity will also have an ``"invalid_key"`` property. Similarly if value deserialization fails and ``"strict"`` is ``false`` then the entity will also have an ``"invalid_value"`` property. ``"headers"`` is optional and will only be present if the message has headers. If present the ``"headers"`` property is an object with string keys and string or bytes values. If the header value is of type bytes then it means that the header value couldn't be deserialized as a string. +The entities emitted from this source has the properties ``"offset"``, ``"partition"``, ``"timestamp"``, ``"key"``, ``"value"``, ``"headers"``. If key deserialization fails and ``"strict"`` is ``false`` then the entity will also have an ``"invalid_key"`` property. Similarly if value deserialization fails and ``"strict"`` is ``false`` then the entity will also have an ``"invalid_value"`` property. ``"headers"`` is optional and will only be present if the message has headers. If present the ``"headers"`` property is an object with string keys and string or bytes values. If the header value is of type bytes then it means that the header value couldn't be deserialized as a string. .. NOTE::