过滤 Confluent Cloud "confluent-audit-log-events" 主题

Question

如何在使用主题时根据环境过滤 Confluent Cloud 集群审计日志：confluent-audit-log-events 在 spring 启动应用程序中？

我正在使用骆驼路线从审计主题中消费。

public void configure() throws Exception {

        from("kafka:confluent-audit-log-events")
                .process(exchange -> {
                    log.info(this.KafkaDetails(exchange));
                });
    }

    private String KafkaDetails(Exchange exchange) {
        return exchange.getIn().getBody(String.class);
    }

Answer 1

最后，我在处理之前使用以下过滤器解决了这个问题。

.filter(body().convertToString().contains(kafkaClusterId))