netcore kafka操做

 

安裝使用：

1：下載nuget包

Confluent.Kafka

librdkafka.redist

System.Runtime.CompilerServices.Unsafe

 基於.net實現kafka的消息隊列應用，經常使用的類庫有kafka-net，Confluent.Kafka，官網推薦使用Confluent.Kafka

 

 

參考：

https://blog.csdn.net/qq_34894585/article/details/83651827

 

 

kafka：

Broker
Kafka集羣包含一個或多個服務器，這種服務器被稱爲broker
Topic
主題：每條發佈到Kafka集羣的消息都有一個類別，這個類別被稱爲Topic。（物理上不一樣Topic的消息分開存儲，邏輯上一個Topic的消息雖然保存於一個或多個broker上但用戶只需指定消息的Topic便可生產或消費數據而沒必要關心數據存於何處）
Partition
分區：Partition是物理上的概念，每一個Topic包含一個或多個Partition.（通常爲kafka節點數cpu的總核數）
Producer
生產者，負責發佈消息到Kafka broker
Consumer
消費者：從Kafka broker讀取消息的客戶端。
Consumer Group
消費者組：每一個Consumer屬於一個特定的Consumer Group（可爲每一個Consumer指定group name，若不指定group name則屬於默認的group）。

可擴展性
    在不須要下線的狀況下進行擴容
    數據流分區(partition)存儲在多個機器上
高性能
    單個broker就能服務上千客戶端
    單個broker每秒種讀/寫可達每秒幾百兆字節
    多個brokers組成的集羣將達到很是強的吞吐能力
    性能穩定，不管數據多大
    Kafka在底層摒棄了Java堆緩存機制，採用了操做系統級別的頁緩存，同時將隨機寫操做改成順序寫，再結合Zero-Copy的特性極大地改善了IO性能。

 

kafka可視化工具

http://www.kafkatool.com/download.html

具體使用可參考：http://www.javashuo.com/article/p-klgbpalp-gd.html