kafka mac 下 啟動 kafka相關

mac 啟動：

zkserver start

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

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

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...