Skip to content

Commit

Permalink
diktat fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
icemachined committed Oct 25, 2023
1 parent 83b1710 commit 5546fc7
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -10,12 +10,14 @@
package com.icemachined.kafka.clients

import com.icemachined.kafka.common.*
import kotlinx.cinterop.*
import kotlinx.coroutines.delay

import librdkafka.*
import platform.posix.size_t
import platform.posix.stdout

import kotlinx.cinterop.*
import kotlinx.coroutines.delay

typealias KafkaNativeProperties = Map<String, String>

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -373,5 +373,4 @@ internal fun rebalanceCallback(
} else if (returnError != RD_KAFKA_RESP_ERR_NO_ERROR) {
logError("rebalanceCallback", "assign failure: ${rd_kafka_err2str(returnError)?.toKString()}")
}

}

0 comments on commit 5546fc7

Please sign in to comment.