Which version of Beam are you using ? Also are you using
notebooks/InteractiveRunner by any chance ?
Thanks,
Cham
On Wed, Feb 24, 2021 at 8:18 AM Carilli Giuseppe <
giuseppe.cari...@expleoitalia.com> wrote:
> 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.
>
