uwenku
標簽列表
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
最新問題
1.
如果語句不適用於循環
2.
在正數變化前增加+符號
3.
將OptimisticLockPolicy更改爲使用本地時間
4.
D3在直線邊緣和多個曲線邊緣之間切換
5.
一旦某件事情完成,我該如何完全停止代碼?
6.
用不同尺寸創建img和p標籤
7.
使用摩卡運行時,仍然會收到語法錯誤,導入爲babel-plugin-syntax-dynamic-import動態導入
8.
UWP視頻導入
9.
在paperjs中的圓段上繪製線
10.
優雅的方式,如果else語句的多組