Skip to content

Commit

Permalink
Update producer/consumer disposal method names to match types
Browse files Browse the repository at this point in the history
Signed-off-by: Michael Edgar <[email protected]>
  • Loading branch information
MikeEdgar committed Oct 22, 2024
1 parent c4dd524 commit ff2bbd7
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -575,7 +575,7 @@ public Consumer<RecordData, RecordData> consumerSupplier(ConsoleConfig consoleCo
context.schemaRegistryContext().valueDeserializer());
}

public void disposeConsumerSupplier(@Disposes Consumer<RecordData, RecordData> consumer) {
public void disposeConsumer(@Disposes Consumer<RecordData, RecordData> consumer) {
consumer.close();
}

Expand All @@ -589,7 +589,7 @@ public Producer<RecordData, RecordData> producerSupplier(ConsoleConfig consoleCo
context.schemaRegistryContext().valueSerializer());
}

public void disposeProducerSupplier(@Disposes Producer<RecordData, RecordData> producer) {
public void disposeProducer(@Disposes Producer<RecordData, RecordData> producer) {
producer.close();
}

Expand Down

0 comments on commit ff2bbd7

Please sign in to comment.