Hi Cham,
I am also getting the same error while using apache-beam==2.28.0
Regards,
Amit
On 2021/02/24 17:02:06, Chamikara Jayalath <chamik...@google.com> wrote:
> 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.
> >
>
