Add reset() to ProducerFactory

Author: garyrussell

spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaProducerFactory.java

@@ -342,6 +342,7 @@ public void onApplicationEvent(ContextStoppedEvent event) {
 	 * {@link Producer}(s).
 	 * @since 2.2
 	 */
+	@Override
 	public void reset() {
 		try {
 			destroy();

spring-kafka/src/main/java/org/springframework/kafka/core/ProducerFactory.java

@@ -79,4 +79,12 @@ default void closeThreadBoundProducer() {
 		// NOSONAR
 	}
 
+	/**
+	 * Reset any state in the factory, if supported.
+	 * @since 2.4
+	 */
+	default void reset() {
+		// NOSONAR
+	}
+
 }

spring-kafka/src/test/java/org/springframework/kafka/core/DefaultKafkaProducerFactoryTests.java

@@ -110,7 +110,7 @@ protected Producer createTransactionalProducer(String txIdPrefix) {
 	@SuppressWarnings({ "rawtypes", "unchecked" })
 	public void testResetSingle() {
 		final Producer producer = mock(Producer.class);
-		DefaultKafkaProducerFactory pf = new DefaultKafkaProducerFactory(new HashMap<>()) {
+		ProducerFactory pf = new DefaultKafkaProducerFactory(new HashMap<>()) {
 
 			@Override
 			protected Producer createKafkaProducer() {