Я создал проект, в котором хочу использовать поток кафки. По этой причине мне нужно использовать KafkaUtils из потоковой передачи искры. Но когда я пытаюсь использовать KafkaUtils, они не могут быть разрешены. Я добавил...

Ниже приведен мой код scala для создания потока spark kafka: val kafkaParams = Map[String, Object]( "bootstrap.servers" -> "server110:2181,server110:9092", "zookeeper" -> "server110:2181", "key.deserializer" ->...

Как настроить Debezium для публикации всех таблиц в базе данных в одной теме Kafka? Является ли это возможным?