如何在使用主题中的内容时根据环境筛选Confluent Cloud群集审核日志：汇合审核日志事件在Spring Boot 应用程序中？
我是用 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);
    }