37 lines
1.5 KiB
Diff
37 lines
1.5 KiB
Diff
|
diff --git a/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala b/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
|
||
|
|
index 2fc55bd7b6..e4611256d4 100755
|
||
|
|
--- a/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
|
||
|
|
+++ b/core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
|
||
|
|
@@ -21,7 +21,6 @@ import java.time.{Duration, Instant}
|
||
|
|
import java.util.Properties
|
||
|
|
import com.fasterxml.jackson.dataformat.csv.CsvMapper
|
||
|
|
import com.fasterxml.jackson.module.scala.DefaultScalaModule
|
||
|
|
-import com.fasterxml.jackson.module.scala.experimental.ScalaObjectMapper
|
||
|
|
import kafka.utils._
|
||
|
|
import kafka.utils.Implicits._
|
||
|
|
import org.apache.kafka.clients.admin._
|
||
|
|
@@ -146,7 +145,7 @@ object ConsumerGroupCommand extends Logging {
|
||
|
|
}
|
||
|
|
// Example: CsvUtils().readerFor[CsvRecordWithoutGroup]
|
||
|
|
private[admin] case class CsvUtils() {
|
||
|
|
- val mapper = new CsvMapper with ScalaObjectMapper
|
||
|
|
+ val mapper = new CsvMapper
|
||
|
|
mapper.registerModule(DefaultScalaModule)
|
||
|
|
def readerFor[T <: CsvRecord : ClassTag] = {
|
||
|
|
val schema = getSchema[T]
|
||
|
|
diff --git a/gradle/dependencies.gradle b/gradle/dependencies.gradle
|
||
|
|
index 8dcf7af2f2..ea0c1af419 100644
|
||
|
|
--- a/gradle/dependencies.gradle
|
||
|
|
+++ b/gradle/dependencies.gradle
|
||
|
|
@@ -66,8 +66,8 @@ versions += [
|
||
|
|
grgit: "4.1.1",
|
||
|
|
httpclient: "4.5.13",
|
||
|
|
easymock: "4.2",
|
||
|
|
- jackson: "2.10.5",
|
||
|
|
- jacksonDatabind: "2.10.5.1",
|
||
|
|
+ jackson: "2.13.4",
|
||
|
|
+ jacksonDatabind: "2.13.4.2",
|
||
|
|
jacoco: "0.8.5",
|
||
|
|
javassist: "3.27.0-GA",
|
||
|
|
jetty: "9.4.48.v20220622",
|