Re: Flink KafkaConsumer metrics in DataDog

We disabled kafka consumer metrics in flink via setting register.consumer.metrics to false in KafkaSource and enabled kafka consumer integration in datadog agent as explained here . On Fri, Aug 27, 2021 at 8:44 AM Deb

Re: Dynamic Cluster/Index Routing for Elasticsearch Sink

Hi again David et al, I managed to push an initial pull request for the implementations for the DynamicElasticsearchSink and related ElasticsearchSinkRouter last week and made some minor updates today with regards to the Javadocs (included code examples