So to clarify, you're using kafka-clients directly? Or via fx2-kafka? If
it's kafka-clients directly, what version please?
On Sat, 19 Mar 2022 at 19:59, Richard Ney wrote:
> Hi Liam,
>
> Sorry for the mis-identification in the last email. The fun of answering an
> email on a phone instead of a d
I am using the kafka-clients through the fs2-kafka wrapper. Thou the log
message I posted and copied again here
Notifying assignor about the new Assignment(partitions=[
platform-data.appquery-platform.aoav3.backfill-28,
platform-data.appquery-platform.aoav3.backfill-31,
platform-data.appquery-plat
Hi Chris,
The broker does take the isolation level in the ListOffset API (which is
used for the endoffset call) in to consideration:
val lastFetchableOffset = isolationLevel match {
case Some(IsolationLevel.READ_COMMITTED) => localLog.lastStableOffset
case Some(IsolationLevel.READ_UNCOMMITTED
Hi Richard,
Yeah, the old 2.8.1 version of Kafka clients used by trunk fs2-kafka is
what I think might be the issue, not the wrapper itself, sorry if I was
unclear on that.
Please let us know how your testing with the latest fs2-kafka that's using
3.1.0 goes. :)
Kind regards,
Liam Clarke-Hutchi
