1回答
: container_name: kafkacat - broker│ ├── Dockerfile│ ├── print_data.sh和kafkacat/Dockerfile：
浏览 19提问于2022-11-01得票数 0
- name: Git clone kafkacat dest={{kafkacat_installdir }} accept_hostkey=yes force=yes
- name: Git clone librdkafkachdir={{ kafkacat_installdir }}/
浏览 0提问于2016-04-26得票数 0
回答已采纳
我使用kafkacat查看标题，但它返回我的kafkacat是1.3，由apt-get install kafkacat安装我使用的完整命令是： -f '\nKey (%K bytes): %k
浏览 8提问于2019-07-08得票数 0
我需要为Kafka生成批处理消息，这样我就有了一个为kafkacat提供信息的文件：-H "id=1"-H "id=2"当我运行上面的kafkacat</
浏览 4提问于2020-05-28得票数 6
我从上读到，kafkacat可以这样做 -f '\nKey (%K bytes): %kValue (%S bytes): %s Partition: %p Headers: %h\n'% ERROR: Failed to acqu
浏览 10提问于2020-12-11得票数 0
create --zookeeper localhost:2181 --replication-factor 1 --partitions 2 --topic betakafkacat-C -b $(boot2docker ip):9092 -t beta -X group.id=mygroupdate | kafkacat -P -b
浏览 1提问于2015-09-25得票数 0
我想使用kafka-console-producer.sh来激发一些带有Kafka头的JSON消息。docker exec -it kafka_1 /opt/kafka_2.12-2.3.0/bin/kafka-console-producer.sh --broker-list localhost:9093 --topic my-topic --producer.config /opt/kafka_2.12-2.3.0/config/my-custom.properties
浏览 2提问于2019-11-06得票数 6
我写了一个ansible剧本，它应该安装一个叫做kafkacat的工具。- name: Install kafkacat (configure) sudo: yes
- name: Install kafka
浏览 0提问于2016-04-25得票数 2
回答已采纳
2回答
-b megalog-try-1_kafka1_1:9092 Lbash-4.4# apt-get install kafkacatbash: apt-get: command not foundexit尝试安装kafkacat后的日志
/ # kafkacat -C -b localhost/releases/download/1.5.0-r0/kafk
浏览 6提问于2020-02-05得票数 1
回答已采纳
2回答
tried to use the samespec: selector: app: kafkacatk8s-app: kube-dns metadata: app: kafkacat spec: - name: kafkacat-contain
浏览 4提问于2020-05-18得票数 2
我是Apache Kafka和Kafkacat的新手，试图从这里学习新东西: time 17:32的。[user@user bin]$ .localhost:2181quickstart-eventstoUpperCase-in-0users-log
当我在kafkacat[user@user bin]$ kafkacat -b localhost:9092 -t toUpp
浏览 6提问于2021-03-15得票数 0
2回答
有没有办法从Kafka集群中收集Kafka生产者配置？我知道这些设置存储在客户端本身。我至少对client.id和生产者要发布到的主题集合感兴趣。
浏览 6提问于2020-05-19得票数 0
我正在尝试通过kafka控制台生产者发送消息。但我不能键入超过4095个字符的消息。尝试搜索生产者或服务器中是否有任何与此相关的属性，但无济于事。甚至尝试搜索是否有任何操作系统特定的限制或标准输入字符限制，但没有找到任何东西。
浏览 10提问于2016-06-08得票数 9
我想在我的MacOS Mojave(10.14.5)上使用kafkacat命令行实用程序(MacOS)。我执行了以下步骤我得到的错误如下
延迟符号绑定失败:符号未找到libSystem.B.dylib中预期的/usr/local/opt/librdkafka/lib/librdkafka.1.dylib引用的_time
浏览 13提问于2019-10-15得票数 4
1回答
我已经安装了kafkacat CLI工具：我试图将borker IP从服务器转发到本地计算机：端口转发工作，但发出kafkacat命令失败：% ERROR:有办法让kafkacat开始工作吗？
浏览 6提问于2020-06-08得票数 0
回答已采纳
\config\server.propertieslisteners=Listener_BOB://:29092,Listener_Kafkacat://127.0.0.1:9092listener.security.protocol.map=Listener_BOB:PLAINTE
浏览 5提问于2020-01-04得票数 5
回答已采纳
我一直试图使用kafkacat在主题中找到一条消息并将其发布回主题中。我们使用protobuf，因此消息值应该以字节为单位(键可以是不同的，例如字符串或字节)。我怎么能用kafkacat做这件事？我也愿意使用其他推荐的工具来做这件事。示例尝试：cat test2.txt | kafkacat -b <但是，当我使用相同的kafkacat使
浏览 6提问于2021-02-23得票数 0
回答已采纳
使用-o (偏移量开始消费)选项执行以下kafkacat命令，但不使用-G (组id)选项会影响其他使用者组吗？kafkacat -C -b 10.52.1.1:9092,10.52.1.2:9092,10.52.1.3:9092 -t MyTopic -o beginning
浏览 2提问于2018-03-29得票数 2
回答已采纳
我正试图在windows机器上安装kafkaCat工具。在通过运行./bootstrap.sh快速构建时，我得到了以下错误：有人知道如何在windows机器上配置kafkaCat吗？
提前谢谢。
浏览 5提问于2017-02-23得票数 6
请帮帮忙我试着用卡夫卡-控制台-消费者和卡夫卡-控制台-制作人来做。for (( i=1; i<=10; i++ )); do bin/kafka-console-consumer.sh --bootstrap-server 1.1.2.3:9092 --group CONSUMER1 --topic TOPIC1 --max-messages 1 > /tmp/_topic/$i.msg; done;
然后我尝试使用卡夫卡-控制台-生产者发送它到t
浏览 9提问于2020-04-02得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
