vamossagar12 commented on PR #13646:
URL: https://github.com/apache/kafka/pull/13646#issuecomment-1591623006
Thanks @sudeshwasnik , for the assessment. Continuing the line of thought,
if you check the `MonitorableSourceConnector#poll` method, it appears to me
that we decrement the `recordsR
vamossagar12 commented on PR #13646:
URL: https://github.com/apache/kafka/pull/13646#issuecomment-1548015263
Thanks @sambhav-jain-16 , @kirktrue , just to give more context, there are
ITs in connect for EOS which rely upon the position() API to assert some
messages ebing read. But they seem
vamossagar12 commented on PR #13646:
URL: https://github.com/apache/kafka/pull/13646#issuecomment-1532658288
Thanks @sambhav-jain-16 . So, one thing that I note is that the
`readEndOffsets` method is using `IsolationLevel.READ_UNCOMMITTED` when reading
the messages while the test uses `read
vamossagar12 commented on PR #13646:
URL: https://github.com/apache/kafka/pull/13646#issuecomment-1527703722
Yeah I agree with @yashmayya . Moreover this
```
Yes it will fail, but consumeAll is not failing due to timeout here but
rather due to its nature of storing the end offsets
