https://github.com/apache/flink/blob/release-1.13.1/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaRecordDeserializationSchema.java#L69
On Wed, Dec 8, 2021 at 12:40 PM Robert Metzger <metrob...@gmail.com> wrote: > Hi Ayush, > > I couldn't find the documentation you've mentioned. Can you send me a link > to it? > > On Tue, Dec 7, 2021 at 10:40 AM Ayush Chauhan <ayush.chau...@zomato.com> > wrote: > >> Hi, >> >> Can you please let me know the alternatives of isEndOfStream() as now >> according to docs this method will no longer be used to determine the end >> of the stream. >> >> -- >> Ayush Chauhan >> Data Platform >> [image: mobile-icon] +91 9990747111 >> >> >> This email is intended only for the person or the entity to whom it is >> addressed. If you are not the intended recipient, please delete this email >> and contact the sender. >> > -- Ayush Chauhan Data Platform [image: mobile-icon] +91 9990747111 -- This email is intended only for the person or the entity to whom it is addressed. If you are not the intended recipient, please delete this email and contact the sender.
