【文件属性】：
文件名称：kt：喜欢JSON的Kafka命令行工具
文件大小：54KB
文件格式：ZIP
更新时间：2021-01-30 19:04:28
cli golang json kafka apache-kafka
kt-一种喜欢JSON的Kafka工具
您可能感兴趣的一些原因：
在特定偏移量之间的特定分区上使用消息。
显示主题信息（例如，具有分区偏移量和领导者信息）。
修改使用者组偏移量（例如，重置或手动设置每个主题和每个分区的偏移量）。
JSON输出，可使用或等工具轻松使用。
JSON输入可通过工具促进自动化。
通过环境变量KT_BROKERS ， KT_TOPIC和KT_AUTH配置代理，主题和认证。
快速启动时间。
没有缓冲输出。
二进制密钥和有效负载可以通过base64或十六进制编码进行传递和呈现。
支持TLS身份验证。
基本集群管理功能：创建和删除主题。
我自己不再主动使用kt，因此，如果您认为它缺少某些功能-请通过创建问题让我知道！
例子
阅读与正则表达式匹配的主题的详细信息$ kt topic -filter news -partitions
{
" name " : " actor-news " ,
" partitions " : [
{
" id " : 0,
" oldest " : 0,
" n
【文件预览】：
kt-master
----topic_test.go(1KB)
----consume_test.go(16KB)
----test-dependencies.yml(1KB)
----.github()
--------workflows()
----produce_test.go(6KB)
----test-secrets()
--------broker1_keystore_creds(7B)
--------kafka.broker1.keystore.jks(4KB)
--------broker1-ca1-signed.crt(1KB)
--------host.producer.ssl.config(300B)
--------snakeoil-ca-1.srl(17B)
--------kt-test.crt(1KB)
--------broker1_sslkey_creds(7B)
--------snakeoil-ca-1.key(2KB)
--------create-certs.sh(2KB)
--------kt-test.csr(928B)
--------broker1.csr(1015B)
--------broker1_truststore_creds(7B)
--------snakeoil-ca-1.crt(1KB)
--------host.consumer.ssl.config(318B)
--------kt-test.key(2KB)
--------auth.json(190B)
--------kafka.broker1.truststore.jks(1KB)
----produce.go(14KB)
----consume.go(18KB)
----LICENSE(1KB)
----topic.go(6KB)
----system_test.go(9KB)
----main.go(2KB)
----common.go(7KB)
----.gitignore(14B)
----Makefile(875B)
----go.sum(8KB)
----README.md(7KB)
----group.go(12KB)
----admin.go(5KB)
----go.mod(392B)