How to send StatsD metrics over AMQP

StatsdConfiguration.java

@Bean
StatsdMeterRegistry statsdMeterRegistry(StatsdConfig config) {
    return StatsdMeterRegistry.builder(config)
            .lineSink(line -> {
                // send this line to AMQP with your broker's client library
            })
            .build();
}

Since you're using Influx, you'll want to use the Telegraf StatsD flavor:

management.metrics.export.statsd.flavor=telegraf

Micrometer uses a variation on Nagle's algorithm to batch up tightly clustered StatsD line emissions into a single payload. You don't need to think about any of this. Just pop off whatever is on the AMQP message and stuff it directly in Telegraf on the high side. Depending on your configuration, you may be able to use the Telegraf AMQP consumer input plugin and not have a custom component on the high side.