spark directstream 消费kafka数据的时候出现报错 java.io.EOFException: Received -1 when reading from channel, socket has likely been closed. val brokers “hadoop:2181” val kafkaParams Map[String,String](“metadata.broker.list” -> brokers, //smallest …
热门系列: 程序人生,精彩抢先看 1.问题
近期忙于开发,自测时发现了如题的一个异常。主要报错信息先贴一下: with root cause com.fasterxml.jackson.databind.exc.InvalidDefinitionException: Cannot construct instance of xx…