java - 过滤 Confluent Cloud “confluent-audit-log-events”主题

Question

如何在使用主题时根据环境过滤 Confluent Cloud 集群审计日志：confluent-audit-log-events in spring boot application？

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

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

标签： javaapache-kafkaapache-camelconfluent-cloud

Answer 1

最后，我在处理之前使用下面的过滤器弄清楚了。

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