在轮询之前使用本机 apache Kafka 消费者 api 过滤消息
Filter messages using native apache Kafka consumers api before poll
是否可以选择在轮询之前使用本机 apache Kafka 消费者过滤消息?
RecordFilterStrategy - 可以在 spring 中看到选项,但在本机 apache kafka 消费者中寻找一些东西 api,并且没有为两个不同主题生成消息的选项。
poll
returns 一个可迭代的记录集合。没有其他方法可以获取记录,因此,您无法预先过滤记录内容(Spring)
是否可以选择在轮询之前使用本机 apache Kafka 消费者过滤消息?
RecordFilterStrategy - 可以在 spring 中看到选项,但在本机 apache kafka 消费者中寻找一些东西 api,并且没有为两个不同主题生成消息的选项。
poll
returns 一个可迭代的记录集合。没有其他方法可以获取记录,因此,您无法预先过滤记录内容(Spring)