当连接建立时,我将从RabbitMQ获取所有消息。我想限制获取RabbitMQ的消息数量。
发布于 2017-07-22 03:45:50
您可以设置以下参数
maxMessagesPerPartition -最大消息数
有关更多详细信息,请参阅spark-rabbitmq。
希望这能帮上忙。
https://stackoverflow.com/questions/45243415
相似问题