diff --git a/api/src/main/java/com/github/streamshub/console/api/ClientFactory.java b/api/src/main/java/com/github/streamshub/console/api/ClientFactory.java index 5ae5bd2f9..d1fc69144 100644 --- a/api/src/main/java/com/github/streamshub/console/api/ClientFactory.java +++ b/api/src/main/java/com/github/streamshub/console/api/ClientFactory.java @@ -575,7 +575,7 @@ public Consumer consumerSupplier(ConsoleConfig consoleCo context.schemaRegistryContext().valueDeserializer()); } - public void disposeConsumerSupplier(@Disposes Consumer consumer) { + public void disposeConsumer(@Disposes Consumer consumer) { consumer.close(); } @@ -589,7 +589,7 @@ public Producer producerSupplier(ConsoleConfig consoleCo context.schemaRegistryContext().valueSerializer()); } - public void disposeProducerSupplier(@Disposes Producer producer) { + public void disposeProducer(@Disposes Producer producer) { producer.close(); }