我們常見(jiàn)的kafka消費(fèi)命令是這樣的:

$KAFKA/bin/kafka-console-consumer.sh --bootstrap-server Desktop:9091 --from-beginning --topic user_behavior

顯然我們希望能把上述命令行做成一個(gè)命令，并且能靈活接收user_behavior這樣的topic參數(shù)

不然每次都需要去網(wǎng)上找一長(zhǎng)串命令或者去翻閱自己的筆記，太麻煩。

我們想要下列形式:

consume 我的topic

這樣的效果，避免尋找和粘貼復(fù)制一長(zhǎng)串的命令，浪費(fèi)時(shí)間．

################################################################################################################

下面是具體配置:

①當(dāng)前語(yǔ)言，確保linux終端的默認(rèn)語(yǔ)言是bash

appleyuchi@Desktop:~$ echo $SHELL
/usr/bin/bash

?

②/home/appleyuchi/scripts/kafka下面新建consume.sh

#!/bin/sh $KAFKA/bin/kafka-console-consumer.sh --bootstrap-server Desktop:9091 --from-beginning --topic $1

新建produce.sh

#!/bin/sh $KAFKA/bin/kafka-console-producer.sh --broker-list Desktop:9091 --topic $1

?

③~/.bashrc中的末尾加入

alias consume='function _blah(){ /home/appleyuchi/scripts/kafka/consume.sh $1;};_blah' alias produce='function _blah(){ /home/appleyuchi/scripts/kafka/produce.sh $1;};_blah'

?

④另外新開個(gè)終端輸入

consume user_behavior

這樣，就可以避免輸入本文開頭長(zhǎng)長(zhǎng)的一大串命令，又可以把topic傳入了，大大提高了調(diào)試kafka的效率。

?

最終實(shí)驗(yàn)效果如下

總結(jié)

以上是生活随笔為你收集整理的kafka消费命令简化(alias中传入参数)的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。