There is no way to end the kafka stream from the deserializer. When would you want to end the stream? Could you explain why you need to end the kafka stream without using the offset?
Ayush Chauhan <ayush.chau...@zomato.com> 于2021年12月8日周三 15:29写道： > > 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. >
