kafka mac 下 啟動 kafka相關

2021-10-12 19:26:47 字數 1204 閱讀 5355

mac 啟動:

zkserver start

kafka-server-start /usr/local/etc/kafka/server.properties

檢視已有topic:

kafka-topics --list --zookeeper localhost:2181

kafka-console-producer --topic topic_a --broker-list localhost:9092
建立消費者

kafka-console-consumer --bootstrap-server localhost:9092 -topic topic_a
幾個重要配置:consumer

enable-auto-commit 預設為true,即offset由kafka維護,設為false後offset由spring維護,offset提交模式可配,設定ackmode的值:

record

每處理一條commit一次

batch(預設)

每次poll的時候批量提交一次,頻率取決於每次poll的呼叫頻率

time

每次間隔acktime的時間去commit

count

累積達到ackcount次的ack去commit

count_time

acktime或ackcount哪個條件先滿足,就commit

manual

listener負責ack,但是背後也是批量上去

manual_immediate

listner負責ack,每呼叫一次,就立即commit

單台機器使用docker安裝啟動kafka

kafaka執行需要zookeeper,docker拉取映象 docker pull wurstmeister zookeeper docker pull wurstmeister kafka啟動 docker run d name zookeeper p 2181 2181 t wurstmeis...

Window下啟動MariaDB服務啟動失敗

今天啟動mariadb,彈出 系統錯誤3 系統路徑找不到 我的天啊,昨天還好好的,想深一層,昨天貌似用過 advanced systemcare 清理過登錄檔 不知道是不是也將mariadb的登錄檔給清理了,重新使用命令mysqld install mariadb 命令安裝也彈出服務已存在。鬱悶啊,...

linux下啟動命令

size large 進入terminal終端,進入dm資料庫安裝成功後的檔案存放目錄,如下所示 ricky localhost cd opt dmdbms 檢視dm資料庫linux下所安裝的檔案,如下所示 ls bin help license en us.txt release notes en...