._import org.apache.flink.streaming.util.serialization.SimpleStringSchemaConfigFactory.load() val brokers = configFactory.getString("kafka.broker")
val to
我使用的是kafka-client版本0.11.0.0。版本更改是可能的,但很繁琐,因此我希望尽可能避免更改版本。我的使用者配置如下所示:bootstrap.servers = # kafka broker with version 0.11.0.0# avoid client id collision with Kafka我在调查这样的信息:
Consum