Fix more typos in docs & Javadocs

Author: NathanQingyangXu

spring-kafka-test/src/main/java/org/springframework/kafka/test/utils/ContainerTestUtils.java

@@ -122,7 +122,7 @@ private static Method getAssignedPartitionsMethod(Class<?> clazz) {
 				method -> theMethod.set(method),
 				method -> method.getName().equals("getAssignedPartitions") && method.getParameterTypes().length == 0);
 		if (theMethod.get() == null) {
-			throw new IllegalStateException(clazz + " has no getAssignedParitions() method");
+			throw new IllegalStateException(clazz + " has no getAssignedPartitions() method");
 		}
 		return theMethod.get();
 	}

spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerAnnotationBeanPostProcessor.java

@@ -265,7 +265,7 @@ public void setApplicationContext(ApplicationContext applicationContext) throws
 
 	/**
 	 * Making a {@link BeanFactory} available is optional; if not set,
-	 * {@link KafkaListenerConfigurer} beans won't get autodetected and an
+	 * {@link KafkaListenerConfigurer} beans won't get auto-detected and an
 	 * {@link #setEndpointRegistry endpoint registry} has to be explicitly configured.
 	 * @param beanFactory the {@link BeanFactory} to be used.
 	 */

spring-kafka/src/main/java/org/springframework/kafka/annotation/RetryableTopic.java

@@ -66,7 +66,7 @@
 	/**
 	 *
 	 * The amount of time in milliseconds after which message retrying should give up and
-	 * send the message to the DLT. Expressions must resolv to a long or a String that can
+	 * send the message to the DLT. Expressions must resolve to a long or a String that can
 	 * be parsed as such.
 	 * @return the timeout value.
 	 *

spring-kafka/src/main/java/org/springframework/kafka/config/StreamsBuilderFactoryBean.java

@@ -193,7 +193,7 @@ public void setStateListener(KafkaStreams.StateListener stateListener) {
 	}
 
 	/**
-	 * Set a {@link StreamsUncaughtExceptionHandler}. Supercedes
+	 * Set a {@link StreamsUncaughtExceptionHandler}. Supersedes
 	 * {@link #setUncaughtExceptionHandler(java.lang.Thread.UncaughtExceptionHandler)}.
 	 * @param streamsUncaughtExceptionHandler the handler.
 	 * @since 2.8

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

@@ -126,7 +126,7 @@ public class KafkaTemplate<K, V> implements KafkaOperations<K, V>, ApplicationCo
 
 	private String defaultTopic;
 
-	private ProducerListener<K, V> producerListener = new LoggingProducerListener<K, V>();
+	private ProducerListener<K, V> producerListener = new LoggingProducerListener<>();
 
 	private String transactionIdPrefix;
 

spring-kafka/src/main/java/org/springframework/kafka/event/ListenerContainerPartitionNoLongerIdleEvent.java

@@ -95,6 +95,6 @@ public String toString() {
 		return "ListenerContainerNoLongerIdleEvent [idleTime="
 				+ ((float) this.idleTime / 1000) + "s, listenerId=" + this.listenerId // NOSONAR magic #
 				+ ", container=" + getSource()
-				+ ", topicPartitios=" + this.topicPartition + "]";
+				+ ", topicPartitions=" + this.topicPartition + "]";
 	}
 }

spring-kafka/src/main/java/org/springframework/kafka/listener/BatchAcknowledgingConsumerAwareMessageListener.java

@@ -41,7 +41,7 @@
 public interface BatchAcknowledgingConsumerAwareMessageListener<K, V> extends BatchMessageListener<K, V> {
 
 	/**
-	 * Invoked with data from kafka. Containers should never call this since it they
+	 * Invoked with data from kafka. Containers should never call this since they
 	 * will detect that we are a consumer aware acknowledging listener.
 	 * @param data the data to be processed.
 	 */

spring-kafka/src/main/java/org/springframework/kafka/listener/CommonLoggingErrorHandler.java

@@ -52,7 +52,7 @@ public void setAckAfterHandle(boolean ackAfterHandle) {
 	public boolean handleOne(Exception thrownException, ConsumerRecord<?, ?> record, Consumer<?, ?> consumer,
 			MessageListenerContainer container) {
 
-		LOGGER.error(thrownException, () -> "Error occured while processing: " + KafkaUtils.format(record));
+		LOGGER.error(thrownException, () -> "Error occurred while processing: " + KafkaUtils.format(record));
 		return true;
 	}
 

spring-kafka/src/main/java/org/springframework/kafka/listener/ContainerProperties.java

@@ -207,7 +207,7 @@ public enum EOSMode {
 	 * {@link org.springframework.kafka.listener.AcknowledgingMessageListener}. Acks will
 	 * be queued and offsets will be committed when all the records returned by the
 	 * previous poll have been processed by the listener.</li>
-	 * <li>MANUAL_IMMDEDIATE: Listener is responsible for acking - use a
+	 * <li>MANUAL_IMMEDIATE: Listener is responsible for acking - use a
 	 * {@link org.springframework.kafka.listener.AcknowledgingMessageListener}. The commit
 	 * will be performed immediately if the {@code Acknowledgment} is acknowledged on the
 	 * calling consumer thread. Otherwise, the acks will be queued and offsets will be
@@ -359,7 +359,7 @@ public void setMessageListener(Object messageListener) {
 	 * {@link org.springframework.kafka.listener.AcknowledgingMessageListener}. Acks will
 	 * be queued and offsets will be committed when all the records returned by the
 	 * previous poll have been processed by the listener.</li>
-	 * <li>MANUAL_IMMDEDIATE: Listener is responsible for acking - use a
+	 * <li>MANUAL_IMMEDIATE: Listener is responsible for acking - use a
 	 * {@link org.springframework.kafka.listener.AcknowledgingMessageListener}. The commit
 	 * will be performed immediately if the {@code Acknowledgment} is acknowledged on the
 	 * calling consumer thread. Otherwise, the acks will be queued and offsets will be

spring-kafka/src/main/java/org/springframework/kafka/listener/DeadLetterPublishingRecoverer.java

@@ -1452,7 +1452,7 @@ public interface ExceptionHeadersCreator {
 		 * @param kafkaHeaders the {@link Headers} to add the header(s) to.
 		 * @param exception The exception.
 		 * @param isKey whether the exception is for a key or value.
-		 * @param headerNames the heaader names to use.
+		 * @param headerNames the header names to use.
 		 */
 		void create(Headers kafkaHeaders, Exception exception, boolean isKey, HeaderNames headerNames);