如何限制從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發送消息的火花數量

回答

相關問題