Re: Quick question about KafkaIO.Write

@Alexey Romanenko thanks so much for your suggestions. Actually I found the below code seems to work. KafkaIO .write() .withBootstrapServers(bootstrapServers) .withTopic(topicName) .withValueSerializer((Class) KafkaAvroSerializer.c

Question regarding GoupByKey operator on unbounded data

Hi Beam community, I got a quick question about GoupByKey operator. According to this doc, if we are using unbounded PCollection, it’s required to specify either non-global windowing

Re: Question regarding GoupByKey operator on unbounded data

Can you explain more about what exactly you are trying to do? On Thu, Dec 10, 2020 at 2:51 PM Tao Li wrote: > Hi Beam community, > > > > I got a quick question about GoupByKey operator. According to this doc > , if > we are us