Justin Pfifer

@gonzalodiaz Your exception indicates something is timing out in Spark. If it's the KCL we would need logs from KCL. For the Spark adapter the KCL runs on a single...

I'm looking into adding this capability, but I don't currently have an ETA.

We don't have an update at this time. This is a feature we are interested adding, and will prioritize it with all customer requests. For all of those interested can...

There is a bug that we're currently fixing which can make GetRecords.IteratorAgeMilliseconds appear to spike to 1 day when first reading from a shard with TRIM_HORIZON, or LATEST. This would...

How often do you checkpoint? This can occur if the lease is lost, and the checkpoint is more than a day old.

@smilykoch I would recommend opening a support case or opening a topic on the [AWS Discussion Forums](https://forums.aws.amazon.com/index.jspa).

@ShibaBandit How long did the call to `processRecords` take? The warning you're getting is telling you that the call to `processRecords` has taken more than the configured time in this...

I'm talking with the SDK team to investigate the NoSuchElementException. The other two exceptions can occur, but should be automatically retried. We're considering changing how some of the exceptions are...

It's currently not possible to override the client in the Python Library. We're currently working on the MultiLang Daemon for 2.0, and will look into supporting private link when explicitly...

Unfortunately the Kinesis Connector Library currently has a direct dependency on a older version of Elasticsearch., and it's a breaking change to update to the newer version. We are looking...