1回答
我目前正在规划一个应用程序的架构，该应用程序从Kafka主题读取数据，并在经过一些转换后将数据转换为RabbitMq。我是Kafka Streams的新手，它们看起来很适合我的任务。但问题是，Kafka服务器托管在另一个供应商的地方，所以我甚至不能安装Cafka Connector to RabbitMq Sink插件。有没有可能编写没有任何Sink点，但只处理输入流的</
浏览 0提问于2021-06-18得票数 0
我在没有RabbitMQ的情况下用Kafka测试MassTransit 我需要一个IBusControl，我可以使用bus.UsingInMemory()吗？使用Kafka ITopicProducers安全吗？像调度/传奇这样的特性是否适用于Kafka或InMemory bus？
浏览 8提问于2020-10-11得票数 0
在讨论卡夫卡和RabbitMQ的区别时，“哑巴经纪人”和“智能经纪人”在与消费者的互动中不断出现。卡夫卡被描述为有一个愚蠢的经纪人，而RabbitMQ据说有一个聪明的经纪人/愚蠢的消费者模型。我熟悉卡夫卡的基础知识，并对RabbitMQ有更多的了解。然而，RabbitMQ的哪些功能使经纪人比卡夫卡更聪明呢？
浏览 5提问于2017-08-28得票数 11
我使用的是confluent的kafka连接器docker image confluentinc/cp-kafka-connect:5.4.0-beta1。我想按照本文中描述的方式设置RabbitMQ源连接器：但是，我不使用本地的kafka代理，而是使用我在账户中设置的代理
在docker-compose.yml中，我通过以下设置
浏览 10提问于2020-05-20得票数 0
回答已采纳
我想了解一下spring云数据流的体系结构。特别是使用它来编排纯粹的批处理管道。我已经在k8s中部署了所有组件，并且注意到我可以在没有中间件(Kafka / RabbitMQ)的情况下部署skipper组件，并通过服务器组件成功地运行批处理作业。根据我可以看到的文档，skipper用于编排流作业。当纯粹用于批处理作业或任务时，skipper (以及随后的Kafka
浏览 0提问于2020-04-23得票数 0
回答已采纳
如何在一次调用中获得发布在单个队列上的所有消息？我必须开发一个java的rest端点。当对该端点进行调用时，我们需要在调用期间读取RabbitMQ上存在的所有消息，并且我需要终止连接，以便它不会连续侦听。
我是Rabbit MQ的新手
浏览 38提问于2021-02-23得票数 0
我已经设置了一个连接器来从RabbitMQ队列中拉出并推送到Kafka主题中。连接器运行，队列清空。但是当我使用kafka-console-consumer或kafkacat查看主题时，每个条目看起来都像一个字节数组- [B@xxxxxxxx。 RabbitMQ消息的有效载荷都是JSON。我需要做些什么才能让JSON从Kafka中恢复过来？我已经在控制台使用者中尝试了value.converter=org.apache.kaf
浏览 22提问于2020-01-07得票数 0
回答已采纳
根据我在文档中看到的，Spring Cloud Dataflow总是需要一个Redis实例才能工作。
是否也可以使用不同的消息代理，例如RabbitMQ？如何在启动期间指定不同的message broker？
浏览 0提问于2016-03-22得票数 0
我是RabbitMQ的新手。我想知道在HA的情况下内存是如何使用的。例如，在Kafka中，如果数据存在或不存在，分区将使用特定数量的内存，复制.In RabbitMQ也是如此，队列是如何分配内存的？HA是如何工作的?镜像队列是否占用每个复制节点相同大小的内存？
浏览 0提问于2017-06-11得票数 1
Kafka集群(由Bitnami编写) 2. Rabbitmq集群(由Bitnami创建) 3. Kubernetes集群(AKS)，可以同时使用Kafka和RMQ。当我在Azure中创建两个集群(Kafka和RMQ)时，我被要求为每个集群创建一个新的资源组。我没有AKS节点的in，所以我不能在集群的虚拟网络中设置异常。我问Azure对这个问题的支持，这是他们的回应：
“我刚刚检查
浏览 0提问于2019-08-07得票数 0
我的目标是在rabbitmq交换队列和kafka主题之间建立一个连接器。我还将plugin.path指向我在camel-rabbitmq-kafka-connector -Standalone.properties中解压缩jars的文件夹。我在CamelRabbitSourceConnector中使用的参数如下： name=CamelRabbitmqSourceConnector
connector
浏览 11提问于2020-09-25得票数 1
回答已采纳
我使用官方的Kafka RabbitMQ连接器从RabbitMQ实例获取JSOn消息。目前，此连接器的配置如下 name=RabbitMQConsentConsumer
connector.class=io.confluent.connect.rabbitmq.RabbitMQSourceConnector=false 使用这种配置，我可以将JSON消息作为字节数组注入到Kafka中，并被读者识别为JSON内容。这是“相当”好
浏览 28提问于2019-04-25得票数 2
我想使用Spark structured来聚合从RabbitMQ消费的数据。我知道与apache kafka有官方的spark结构化流媒体集成，我想知道是否也存在与RabbitMQ的集成？由于我不能切换现有的消息传递系统(RabbitMQ)，我想使用kafka-connect在消息传递系统(Rabbit to kafka)之间移动数据，然后使用Spark stru
浏览 0提问于2018-04-16得票数 0
使用独立模式，我创建了一个连接器，并进行了如下定制的转换：connector.class=com.github.jcustenborder.kafka.connect.rabbitmq.RabbitMQSourceConnector我在文档中找不到任何例子。有趣的是，Landoop的Ui特性“转换为curl”与我的第二个示例产生的json完全相同)为了确保这与Lan
浏览 17提问于2017-09-08得票数 1
回答已采纳
我正在尝试使用InsertField卡夫卡连接转换和rabbitmq连接器。我的配置： "connector.class": "io.confluent.connect.rabbitmq.RabbitMQSourceConnector="events", body=msg)Cau
浏览 3提问于2022-10-18得票数 0
回答已采纳
我试图用卡夫卡-连接一个rabbitMQ连接器来验证概念。基本上，我有两个简单的spring引导应用程序:一个RabbitMQ生产者和一个卡夫卡消费者。使用者无法处理来自连接器的消息，因为它正在以某种方式转换我的JSON消息；RabbitMQ发送{"transaction": "PAYMENT", "amount": "$125.0"}和kafka-connect请注意开头
浏览 0提问于2020-01-07得票数 1
回答已采纳
我想用RabbitMQ和Kafka的地铁做消息经纪人。我在启动.Net核心应用程序时配置了.Net和Kafka，在部署阶段通过appSetting可以决定哪一个必须注册。这种方法对于在我的应用程序中同时拥有和配置Kafka和
浏览 0提问于2021-03-03得票数 1
回答已采纳
我有一个服务需要建模为流应用程序(该服务为当前相同的用例提供了同步和异步api )。我正在探索是否可以将实际处理建模为流应用程序。由于处理阶段保持不变，真正的区别是服务接口( http消息传递协议)。ProcessorsAsync Sync == Http Binder <-> (req/resp) Api == RabbitMQ/Kafka Binder-
浏览 2提问于2021-01-04得票数 0
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
