回答情况：
提问时间：
问题标签：
我有一个场景，多个客户端希望生成和使用消息。是否有办法在apache中实现多租户，以便一个客户能够通过另一个客户的大量流入而保持完整。基本上，我想要一种将客户端标记到代理的方法，而该客户端上的所有主题/分区都属于标记的代理。在这里，一个客户端在内部生成和使用消息。他们这样做是为了实现分布式处理。父消息被分解为子消息，并在任何机器中产生/处理这些子消息。
浏览 3提问于2020-09-02得票数 1
我正在使用Flutter，我需要将数据写入Kafka。我怎样才能在扑翼/飞镖中做到这一点..有没有可以使用的Kafka客户端？ 谢谢你的帮忙
浏览 56提问于2019-06-03得票数 3
我试图找出卡夫卡制片人的设置batch.size和buffer.memory之间的区别。文档将buffer.memory描述为:生产者可以用来缓冲等待发送的记录的内存字节。谢谢
浏览 0提问于2018-04-04得票数 16
背景工具问题--files <file1, file2, ...> REQUIRED: The comma separated list of 有没有办法查看目录下的所有文件？尝试了*log，但它只在目录中的第一个文件中显示。编写一个小程序是唯一的选择吗？
浏览 0提问于2017-03-23得票数 0
回答已采纳
在SCALA代码中使用Kafka/FLink命令行-“命令”是否有一个Scala来控制命令行接口命令的执行.因此，根据应用程序中的条件，我可以向flink提交一个作业，并从代码中创建/删除kafka。Starting Flink Server bin/stop-local.sh
bin/flink run -c pathToMai
浏览 7修改于2017-10-09得票数 0
回答已采纳
我试图使用MySQL将事件流到PostgreSQL，尽管插入和更新工作正常，但我不知道如何从MySQL中删除记录并将该事件流到PostgreSQL。 +-------------+ | MySQL | +------+------+ |
浏览 4修改于2018-08-03得票数 5
是否可以使用SharedAccessKey连接到代理(EventHubs)？我们使用SharedAccessKey而不是SSL来连接，我有这样的配置。
"SaslMechanism": "Pla
浏览 0修改于2020-04-30得票数 1
我有一个关于python中使用kafka模块的代码的问题，我真的不知道为什么它不能工作。在我像建议的那样初始化了ZooKeep&Kafka服务器并在我的计算机上创建主题之后，我尝试使用Termux在我的智能手机上运行以下代码：from kafka import KafkaProducer, KafkaConsumer
self.output_publisher = KafkaProducer(bootstrap_
浏览 1提问于2019-03-22得票数 0
回答已采纳
我的目标是使用debezium-connectors.和apache-kafka将数据更改流到新的数据库表中。但我一点也不知道怎么做到这一点。
浏览 6修改于2022-06-04得票数 1
HDP 2.6.5无路肩我正在为kafka中的特定主题编写数据，并试图运行python代码来读取和显示kafka的数据。启动火花放电：在火花放电壳中：
from pyspark.
浏览 1修改于2020-05-13得票数 1
C:\xxx\apache-kafka\kafka_2.13-2.4.0\bin\windows>connect-distributed.bat C:\xxx\apache-kafka\kafka_2.13-0.7.0.jar;C:\xxx\apache-kafka\kafka_2.13-2.4.0\libs\audience-annotations-0.5.0.jar;C:\xxx\apache-kafka.jar;C:\xxx\apache-kafka\kafka_2.13-2.4.0\libs
浏览 3修改于2020-01-24得票数 0
我从链接中下载了Scala2.11-kafka_2.11-2.1.0.tgz：和我完成了以下步骤：
>kafka-server-start.bat C:\Apache-Kafka\kafka_2.11-2.1.0\configC
浏览 0修改于2020-04-21得票数 2
我正试图使用apache-kafka二进制文件中的kafka-控制台-生产者来生成消息，并在春季启动时从消费者设置中消费。使用者使用avro架构。是否有一种方法可以使用apache-kafka与kafka控制台生产者一起使用avro模式来生成/消费消息？
浏览 6提问于2022-04-26得票数 0
回答已采纳
nix-env -i apache-kafka
sudo systemctl start apache-kafka # Failed to start apache-kafka.service: Unit
浏览 0修改于2017-03-05得票数 13
我已经通过马拉松发布了包含DC/OS1.7中的apache-kafka包的Confluent 2，参见。
浏览 6修改于2016-05-19得票数 3
回答已采纳
我使用apache-kafka和web通量(spring )，我想知道是否有一种方法可以为我在KafkaListener (或属性)中添加的每个主题自动创建一个application.yml。
浏览 3修改于2022-06-14得票数 -1
但是，这似乎没有执行，因为在前面我在日志中看到的情况下，来自apache-kafka的apache-kafka正在“发送元数据请求”，然后响应说：
topics=[MetadataResponseTopic
浏览 11提问于2022-10-03得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号