File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
sdks/python/apache_beam/io Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -294,11 +294,11 @@ def __init__(
294294
295295 :param producer_config: A dictionary containing the producer configuration.
296296 :param topic: A Kafka topic name.
297- :param key_deserializer : A fully-qualified Java class name of a Kafka
297+ :param key_serializer : A fully-qualified Java class name of a Kafka
298298 Serializer for the topic's key, e.g.
299299 'org.apache.kafka.common.serialization.LongSerializer'.
300300 Default: 'org.apache.kafka.common.serialization.ByteArraySerializer'.
301- :param value_deserializer : A fully-qualified Java class name of a Kafka
301+ :param value_serializer : A fully-qualified Java class name of a Kafka
302302 Serializer for the topic's value, e.g.
303303 'org.apache.kafka.common.serialization.LongSerializer'.
304304 Default: 'org.apache.kafka.common.serialization.ByteArraySerializer'.
You can’t perform that action at this time.
0 commit comments