如何限制从RabbitMQ发送消息的火花数量

当连接建立时，我从RabbitMQ获取所有消息。我想限制获取RabbitMQ的消息数量。如何限制从RabbitMQ发送消息的火花数量

来源

2017-07-21 Chandrasekhar Vasamsetti

您可以设置以下参数

maxMessagesPerPartition - 消息的最大数量

详情请参阅spark-rabbitmq。

希望这有助于。

来源

2017-07-21 19:45:50

是的，我们有火花属性，但这里的问题是RabbitMQUtils.createStream（ssc，rabbitMQConnection）。我正在设置queueName，主机，端口，虚拟主机，用户名和密码。如果我尝试在rabbitMQConnection参数中设置MaxMessagesPerPartition。这是说没有签名的方法。我不确定在哪里设置此属性。 –

如何限制从RabbitMQ发送消息的火花数量

回答

相关问题