C#訂閱Kafka消息一直不能消費的情況怎么處理？

最近跟數據部門對接時對方提供的kafka訂閱服務，於是找了資料，寫了個C#控制台程序消費了這個服務。 本文主要記錄的內容是C#消費Kafka消息時選用kafka-net組件，遇到offset不是從0開始的情況時處理方法。 按照入門教程搭建測試環境並調試一切正常。 在生產環境中部署后遇到一直 ...

基於kafka-net實現的可以長鏈接的消息生產者

　　今天有點時間，我就來說兩句。最近接觸的Kafka相關的東西要多一些，其實以前也接觸過，但是在項目使用中的經驗不是很多。最近公司的項目里面使用了Kafka消息中間件，由於以前的人員編寫的客戶 ...