消息從事件中心後不流

[Jreco]

嗨,團隊,

我想構建一個實時解決方案使用磚和事件的中心。

奇怪的事情發生了一段時間後,這個過程開始。

在消息流開始通過與這個過程預計率:

請注意,最後更新時間是50秒。

然而,過了一段時間後,消息不流:

請注意,最後更新時間:11小時。

如果我重新啟動工作,再次如預期的消息流(甚至恢複的消息並不在拉斯維加斯11個小時處理,對於這種情況)

這是一個問題的示例圖:

最後peek是當我重新啟動工作。

知道發生了什麼嗎?

[Hubert_Dudek1 · Accepted solution]

• 請檢查.option (“checkpointLocation”、“/ mnt / your_storage /”)指定為結構化流,
• 它也取決於什麼是比用流(writeStream),
• 連接eventhub相當直接,請核實也流在Azure的一麵,因為我們可以看到實時流媒體信息(甚至進入實體,選擇中心,在“期貨”選擇“流程數據”比“探索”比“創建”)

[Jreco]

謝謝你的回答@Hubert杜德克,

• 已經指定
• 你是什麼意思呢?
• 這是奇怪的一部分,由於數據流動好,但是就像任何時候工作停止閱讀或這樣的半場進攻,如果我重新啟動工作,繼續工作

[Hubert_Dudek1]

我的意思是,你讀流在某些目的,通常將它和寫的地方。所以問題不可以閱讀,但寫作部分。

[Jreco]

我假設這個問題不是寫一部分,因為數據庫不存在任何阻滯劑或衝突。