[Error] Unknown Coder URN java.lang.IllegalArgumentException: Unknown Coder URN beam:coder:pickled_python:v1 when running apache_beam.io.kafka.WriteToKafka

Wed, 24 Feb 2021 08:18:01 -0800 

Hello,

I'm receiving the error java.lang.IllegalArgumentException: Unknown Coder URN 
beam:coder:pickled_python:v1  when running apache_beam.io.kafka.WriteToKafka.

This is the transformation that gives me the error (The implementation should 
be correct):


from apache_beam.io.kafka import WriteToKafka



...



(my_pcollection

| 'Write to Kafka topic' >> WriteToKafka(
   producer_config={"bootstrap.servers": "localhost:9092"},
   topic="my_topic",
   key_serializer="org.apache.kafka.common.serialization.ByteArraySerializer",
   value_serializer="org.apache.kafka.common.serialization.ByteArraySerializer",
   ))

Can you please give me support on this?

Thank you.

Reply via email to