过滤合流云“Confluent -events log-events”主题

Question

如何根据环境筛选合流云集群审计日志，同时使用主题: spring应用程序中的confluent-audit-log-events？

我正在使用camel路径来使用审计主题。

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))