小编sir*_*mar的帖子

我在卡夫卡（Kafka）遇到过这样的情况，生产者以比消费者消费率高得多的速度发布消息。我必须在kafka中实施反压实现，以进一步消耗和处理。

请让我知道如何在spark和普通的Java API中实现。