【发布时间】：2017-07-22 03:45:50
【问题描述】：
建立连接后，我会从 RabbitMQ 获取所有消息。我想限制获取 RabbitMQ 的消息数量。
【问题讨论】：
标签： apache-spark rabbitmq spark-streaming
【发布时间】：2017-07-22 03:45:50
【问题描述】：
【讨论】：
-
是的，我们有 spark 属性，但这里的问题是 RabbitMQUtils.createStream(ssc, rabbitMQConnection)。我正在设置 queueName、主机、端口、虚拟主机、用户名和密码。如果我尝试在 rabbitMQConnection 参数中设置 MaxMessagesPerPartition。就是说没有具有该签名的方法。我不确定在哪里设置此属性。