zkclient

0熱度

1回答

zkClient不能被Serializabled，sparkstreaming寫kafka偏移量到zookeeper

我的項目包括ZooKeeper，Kafka和Spark Streaming。問題是zkClient當我嘗試使用Spark Streaming向ZooKeeper寫入Kafka偏移量時，無法序列化。我見過幾個GitHub的項目，如：https://github.com/ippontech/spark-kafka-source //save the offsets kafkaStream.fore

scala apache-kafka apache-zookeeper zkclient 2017-05-27

---