1 接続が確立されたら、RabbitMQからすべてのメッセージを受信しています。私は、RabbitMQをフェッチするメッセージの数を制限したい。RabbitMQからのメッセージ数を制限する方法 出典 2017-07-21 Chandrasekhar Vasamsetti
1 あなたは、パラメータ maxMessagesPerPartition以下に設定することができます - 詳細は、メッセージ 参照spark-rabbitmqの最大数。 これが役に立ちます。 出典 2017-07-21 19:45:50 +0 はい、私たちはスパークのプロパティを持っていますが、ここでの問題はRabbitMQUtils.createStream(ssc、rabbitMQConnection)です。私はqueueName、ホスト、ポート、仮想ホスト、ユーザー名とパスワードを設定しています。私がrabbitMQConnectionパラメータでMaxMessagesPerPartitionを設定しようとすると。その署名を持つメソッドは存在しないと言っています。私はこのプロパティを設定する場所がわかりません。 –
はい、私たちはスパークのプロパティを持っていますが、ここでの問題はRabbitMQUtils.createStream(ssc、rabbitMQConnection)です。私はqueueName、ホスト、ポート、仮想ホスト、ユーザー名とパスワードを設定しています。私がrabbitMQConnectionパラメータでMaxMessagesPerPartitionを設定しようとすると。その署名を持つメソッドは存在しないと言っています。私はこのプロパティを設定する場所がわかりません。 –