We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bda34ae commit 9647fecCopy full SHA for 9647fec
src/main/kotlin/io/github/nomisRev/kafka/receiver/internals/CommittableBatch.kt
@@ -93,7 +93,7 @@ internal class CommittableBatch {
93
fun getAndClearOffsets(): CommitArgs {
94
val offsetMap: MutableMap<TopicPartition, OffsetAndMetadata> = HashMap()
95
if (outOfOrderCommits) {
96
- deferred.forEach { (tp: TopicPartition, offsets: List<Long>) ->
+ deferred.forEach { (tp: TopicPartition, offsets: MutableList<Long>) ->
97
if (offsets.size > 0) {
98
offsets.sort()
99
val uncomittedThisPart: MutableList<Long> = uncommitted[tp]!!
0 commit comments