Pull isTransactional() up to KafkaOperations

Author: garyrussell

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

@@ -209,6 +209,14 @@ public interface KafkaOperations<K, V> {
 	 */
 	void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets, String consumerGroupId);
 
+	/**
+	 * Return true if the implementation supports transactions (has a transaction-capable
+	 * producer factory).
+	 * @return true or false.
+	 * @since 3.2
+	 */
+	boolean isTransactional();
+
 	/**
 	 * A callback for executing arbitrary operations on the {@link Producer}.
 	 * @param <K> the key type.

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

@@ -149,12 +149,7 @@ public void setMessageConverter(RecordMessageConverter messageConverter) {
 		this.messageConverter = messageConverter;
 	}
 
-	/**
-	 * Return true if this template supports transactions (has a transaction-capable
-	 * producer factory).
-	 * @return true or false.
-	 * @since 2.1.3
-	 */
+	@Override
 	public boolean isTransactional() {
 		return this.transactional;
 	}