I haven't been able to reproduce this. Do you have a stack trace ?
Thanks,
Cham
On Thu, Mar 4, 2021 at 8:54 AM Amit Saraswat <amit5...@gmail.com> wrote:
> 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.
> > >
> >
>
