tijoparacka opened a new issue #9582: Kinesis ingestion is getting reset because of time out. URL: https://github.com/apache/druid/issues/9582 I think there is a logical bug in KineisisRecordSupplier#getSequenceNumberInternal . The timeout calculated for each sharditerator is not resetting after a new sharditerator is retrieved. ### Affected Version All versions ### Description This issue will happen when there is no data coming to a shard for more than the timeout set in fetchSequenceNumberTimeout. AWS document mention that the timeout can be up to 5 min. The fix is to reset the timeout value after a new sharditerator is initialized.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
