[2024-01-17/22:10:50.210/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 102 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:50.204/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 104 log end offset (LEO) position 390 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:50.210/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 104 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:50.210/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 104 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:50.706/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 103 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:50.707/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 103 log end offset (LEO) position 390 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:50.707/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 103 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:50.708/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 103 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:50.710/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 102 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:50.711/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 102 log end offset (LEO) position 390 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:50.711/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 102 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:50.711/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 102 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:50.711/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 104 log end offset (LEO) position 390 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:50.711/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 104 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:50.712/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 104 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.211/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 103 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.212/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 103 log end offset (LEO) position 390 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.212/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 103 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.213/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 103 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.214/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 104 log end offset (LEO) position 390 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.213/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 102 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.215/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 102 log end offset (LEO) position 390 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.216/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 102 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.216/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 102 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.214/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 104 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.217/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 104 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.718/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 103 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.718/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 103 log end offset (LEO) position 390 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.718/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 102 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.718/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 104 log end offset (LEO) position 390 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.719/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 104 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.719/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 104 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.719/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 102 log end offset (LEO) position 390 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.720/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 102 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.719/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 103 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.720/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 103 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.720/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 102 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.867/IST] TRACE [Partition foo.test-0 broker=101] Skipping update high watermark since new hw (offset=390, segment=[0:6347980]) is not larger than old value. All current LEOs are Set(replica 102: (offset=390, segment=[0:6347980]), replica 103: (offset=390, segment=[0:6347980]), replica 104: (offset=390, segment=[0:6347980]), replica 101: (offset=391, segment=[0:6372889])) (kafka.cluster.Partition)
[2024-01-17/22:10:51.871/IST] TRACE [Partition foo.test-0 broker=101] Progress awaiting ISR acks for offset 391: acked: Set(broker 101: 391), awaiting Set(broker 102: 390, broker 103: 390, broker 104: 390) (kafka.cluster.Partition)
[2024-01-17/22:10:51.875/IST] TRACE [Partition foo.test-0 broker=101] Progress awaiting ISR acks for offset 391: acked: Set(broker 101: 391), awaiting Set(broker 102: 390, broker 103: 390, broker 104: 390) (kafka.cluster.Partition)
[2024-01-17/22:10:51.883/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 104 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.885/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 104 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.886/IST] TRACE [Partition foo.test-0 broker=101] Skipping update high watermark since new hw (offset=390, segment=[0:6347980]) is not larger than old value. All current LEOs are Set(replica 102: (offset=390, segment=[0:6347980]), replica 103: (offset=390, segment=[0:6347980]), replica 104: (offset=391, segment=[0:6372889]), replica 101: (offset=391, segment=[0:6372889])) (kafka.cluster.Partition)
[2024-01-17/22:10:51.886/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 104 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.892/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 102 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.892/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 103 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.893/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 103 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.893/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 103 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.894/IST] TRACE [Partition foo.test-0 broker=101] Skipping update high watermark since new hw (offset=390, segment=[0:6347980]) is not larger than old value. All current LEOs are Set(replica 102: (offset=390, segment=[0:6347980]), replica 103: (offset=391, segment=[0:6372889]), replica 104: (offset=391, segment=[0:6372889]), replica 101: (offset=391, segment=[0:6372889])) (kafka.cluster.Partition)
[2024-01-17/22:10:51.894/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 103 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.893/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 102 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.894/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 102 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:51.895/IST] DEBUG [Partition foo.test-0 broker=101] High watermark updated from (offset=390, segment=[0:6347980]) to (offset=391, segment=[0:6372889]) (kafka.cluster.Partition)
[2024-01-17/22:10:51.898/IST] TRACE [Partition foo.test-0 broker=101] Progress awaiting ISR acks for offset 391: acked: Set(broker 102: 391, broker 103: 391, broker 104: 391, broker 101: 391), awaiting Set() (kafka.cluster.Partition)
[2024-01-17/22:10:51.898/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 102 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.390/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 104 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.391/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 104 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.391/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 104 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.398/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 103 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.399/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 103 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.409/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 103 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.414/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 103 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.421/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 102 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.421/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 102 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.421/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 102 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.422/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 102 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.894/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 104 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.894/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 104 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.894/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 104 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.921/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 103 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.921/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 103 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.921/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 103 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.922/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 103 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.922/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 102 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.922/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 102 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.922/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 102 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:52.923/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 102 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.403/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 104 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.410/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 104 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.422/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 104 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.431/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 103 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.431/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 102 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.432/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 103 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.432/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 103 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.432/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 103 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.432/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 102 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.432/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 102 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.433/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 102 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.932/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 104 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.933/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 104 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.933/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 104 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.935/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 103 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.935/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 103 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.935/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 103 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.936/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 103 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.934/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 102 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.937/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 102 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.937/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 102 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:53.937/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 102 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.438/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 104 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.440/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 104 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.441/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 104 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.440/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 103 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.443/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 103 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.443/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 103 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.443/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 103 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.440/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 102 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.444/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 102 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.445/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 102 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.445/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 102 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.943/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 104 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.946/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 104 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.947/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 104 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.946/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 103 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.950/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 103 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.951/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 103 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.964/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 103 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.948/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 102 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.965/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 102 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.966/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 102 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:54.966/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 102 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.452/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 104 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.453/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 104 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.454/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 104 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.468/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 103 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.470/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 103 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.471/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 103 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.472/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 103 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.469/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 102 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.482/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 102 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.484/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 102 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.485/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 102 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.955/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 104 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.956/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 104 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.956/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 104 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.978/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 103 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.980/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 103 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.981/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 103 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.981/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 103 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.991/IST] DEBUG [Partition __consumer_offsets-0 broker=101] Recorded replica 102 log end offset (LEO) position 6 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.992/IST] DEBUG [Partition foo.test-8 broker=101] Recorded replica 102 log end offset (LEO) position 372 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.992/IST] DEBUG [Partition foo.test-6 broker=101] Recorded replica 102 log end offset (LEO) position 404 and log start offset 0. (kafka.cluster.Partition)
[2024-01-17/22:10:55.994/IST] DEBUG [Partition foo.test-0 broker=101] Recorded replica 102 log end offset (LEO) position 391 and log start offset 0. (kafka.cluster.Partition)