From 38c079fa1e5761524559c395bf3ec76fe7aadfff Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?P=C3=A9ter=20Sin=C3=B3ros-Szab=C3=B3?= Date: Mon, 9 Sep 2024 18:12:48 +0200 Subject: [PATCH] add autoconfiguration in case we don't have a PP for the Producer --- .../kafka/tkms/config/TkmsAutoConfiguration.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/tw-tkms-starter/src/main/java/com/transferwise/kafka/tkms/config/TkmsAutoConfiguration.java b/tw-tkms-starter/src/main/java/com/transferwise/kafka/tkms/config/TkmsAutoConfiguration.java index b9f8b61..4aa822c 100644 --- a/tw-tkms-starter/src/main/java/com/transferwise/kafka/tkms/config/TkmsAutoConfiguration.java +++ b/tw-tkms-starter/src/main/java/com/transferwise/kafka/tkms/config/TkmsAutoConfiguration.java @@ -37,8 +37,6 @@ public IMeterCache twDefaultMeterCache(MeterRegistry meterRegistry) { return new MeterCache(meterRegistry); } - - @Bean @ConditionalOnMissingBean(ITransactionsHelper.class) public TransactionsHelper twTransactionsHelper() { @@ -51,4 +49,9 @@ public List messageDecorators() { return Collections.emptyList(); } + @Bean + @ConditionalOnMissingBean(ITkmsKafkaProducerPostProcessor.class) + public List producerPostProcessors() { + return Collections.emptyList(); + } }