• Mac下安装kafkacat

kafkacat 是kafka的一个命令行客户端。

$ brew install kafkacat

• 查看Topic集群：

kafkacat -L -b 10.213.42.230:10062 -t gateway_log

• 发送消息（从文件中读取）

$ tail -10f nginx.log | kafkacat -P -b 10.213.42.230:10062 -t gateway_log

• 发送消息（从终端输入）

$  kafkacat -P -b 10.213.42.230:10062 -t gateway_log

• 接收消息

$ kafkacat -C -b 10.213.42.230:10062 -t gateway_log

附录1： Gateway 日志样例

2016/08/24 22:19:27 [notice] 139724#0: *5433663079 [lua] gateway.lua:156: log(): [GatewayMonV2] [200], [345], [200, 0.0039999485015869, 0.0039999485015869, 1472048367.833, 1969], [1472048367.833, 10.209.37.13, -, 657], [-, 10.209.230.191-1472048367.833-139724-3687, 1.4], [true, -, -, -, -, -, SESSIONID=deleted; SESSIONID=deleted; psid=1eacacb429cd6c1a17ddab20a0193a1f; sid=825c3427b5c9d60657f4d4ab6a31cadc; uniqkey2=RZhczLgfkoQJoTrJSECaHMn/C4Di/FBU2dBe8eL6C1D10Y8NkRqQEGFgrM3BUyzzmK7f7YsDBlRbEQGd/HwTx2npUQcYxYaMURBeJ1M2f3L1WDYsIt5miiDR2FABUmVoR8kjnTU0TqLMQ9wD7h3hODaOBd3uKxf51Q6R879Izon5bxKLdf8aUq+p0LyRjqUSjNI=; uid=3849470368986201; puid=381980BCEDE34A6F90B62A9133835609; up=bup; CITY_ID=110100; SHARE_STRING_ADID=GP1470879895201000000; sid=825c3427b5c9d60657f4d4ab6a31cadc, -], [{"{{pno}}":"20160704101902"}], [117.25.58.218, -, 10.209.37.13, 10.209.37.13], [-], [-], [-, -, -, -, -, -, -, -, -, -, -], [-End-] while sending to client, client: 10.209.37.13, server: localhost, request: "GET /coupon/v2/products/20160704101902?source=1&_realip=117.25.58.218&__uni_source=1.4 HTTP/1.1", host: "api.ffan.com"

直接在终端输入，不方便。可以保存到文件，然后从文件中读取。