2017-07-21 13 views

答えて

1

あなたは、パラメータ

maxMessagesPerPartition以下に設定することができます - 詳細は、メッセージ

参照spark-rabbitmqの最大数。

これが役に立ちます。

+0

はい、私たちはスパークのプロパティを持っていますが、ここでの問題はRabbitMQUtils.createStream(ssc、rabbitMQConnection)です。私はqueueName、ホスト、ポート、仮想ホスト、ユーザー名とパスワードを設定しています。私がrabbitMQConnectionパラメータでMaxMessagesPerPartitionを設定しようとすると。その署名を持つメソッドは存在しないと言っています。私はこのプロパティを設定する場所がわかりません。 –

関連する問題