Missing required configuration "key.serializer" which has no default value.

SparkStreaming写入Kafka报错Missing required configuration "key.serializer" which has no default value. 这是由于你在KafkaParams参数时没有指定key.serializer 将KafkaParams配置项设置为如下格式就ok了 /** * 设置Kafka参数 */ val kafkaPar
相关文章
相关标签/搜索