From 3111304c823e169ff562017ce8e1a2ad7af7218e Mon Sep 17 00:00:00 2001 From: Arun Date: Fri, 28 Nov 2025 15:18:34 +0530 Subject: [PATCH] Fix typo in WriteToKafka docstring: deserializer -> serializer Fixed documentation parameter names in WriteToKafka.__init__: - key_deserializer -> key_serializer - value_deserializer -> value_serializer Fixes #36931 --- sdks/python/apache_beam/io/kafka.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sdks/python/apache_beam/io/kafka.py b/sdks/python/apache_beam/io/kafka.py index 09063fb0828f..b63366393252 100644 --- a/sdks/python/apache_beam/io/kafka.py +++ b/sdks/python/apache_beam/io/kafka.py @@ -294,11 +294,11 @@ def __init__( :param producer_config: A dictionary containing the producer configuration. :param topic: A Kafka topic name. - :param key_deserializer: A fully-qualified Java class name of a Kafka + :param key_serializer: A fully-qualified Java class name of a Kafka Serializer for the topic's key, e.g. 'org.apache.kafka.common.serialization.LongSerializer'. Default: 'org.apache.kafka.common.serialization.ByteArraySerializer'. - :param value_deserializer: A fully-qualified Java class name of a Kafka + :param value_serializer: A fully-qualified Java class name of a Kafka Serializer for the topic's value, e.g. 'org.apache.kafka.common.serialization.LongSerializer'. Default: 'org.apache.kafka.common.serialization.ByteArraySerializer'.