Fix some typos.

Author: neetkee

spring-kafka-test/src/main/java/org/springframework/kafka/test/hamcrest/KafkaMatchers.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2016-2018 the original author or authors.
+ * Copyright 2016-2019 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -66,7 +66,7 @@ public static <V> Matcher<ConsumerRecord<?, V>> hasValue(V value) {
 	}
 
 	/**
-	 * Matcher testing the timestamp of a {@link ConsumerRecord} asssuming the topic has been set with
+	 * Matcher testing the timestamp of a {@link ConsumerRecord} assuming the topic has been set with
 	 * {@link org.apache.kafka.common.record.TimestampType#CREATE_TIME CreateTime}.
 	 * @param ts timestamp of the consumer record.
 	 * @return a Matcher that matches the timestamp in a consumer record.

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2016-2018 the original author or authors.
+ * Copyright 2016-2019 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -180,7 +180,7 @@ private void enableIdempotentBehaviour() {
 
 	/**
 	 * Set to false to revert to the previous behavior of a simple incrementing
-	 * trasactional.id suffix for each producer instead of maintaining a producer
+	 * transactional.id suffix for each producer instead of maintaining a producer
 	 * for each group/topic/partition.
 	 * @param producerPerConsumerPartition false to revert.
 	 * @since 1.3.7

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

@@ -277,7 +277,7 @@ protected void doStart() {
 		}
 		Assert.state(messageListener instanceof GenericMessageListener, "Listener must be a GenericListener");
 		GenericMessageListener<?> listener = (GenericMessageListener<?>) messageListener;
-		ListenerType listenerType = deteremineListenerType(listener);
+		ListenerType listenerType = determineListenerType(listener);
 		this.listenerConsumer = new ListenerConsumer(listener, listenerType);
 		setRunning(true);
 		this.listenerConsumerFuture = containerProperties
@@ -298,7 +298,7 @@ private void checkAckMode(ContainerProperties containerProperties) {
 		}
 	}
 
-	private ListenerType deteremineListenerType(GenericMessageListener<?> listener) {
+	private ListenerType determineListenerType(GenericMessageListener<?> listener) {
 		ListenerType listenerType = ListenerUtils.determineListenerType(listener);
 		if (listener instanceof DelegatingMessageListener) {
 			Object delegating = listener;
@@ -693,7 +693,7 @@ public void run() {
 			}
 			this.count = 0;
 			this.last = System.currentTimeMillis();
-			initAsignedPartitions();
+			initAssignedPartitions();
 			while (isRunning()) {
 				try {
 					pollAndInvoke();
@@ -722,7 +722,7 @@ public void run() {
 			wrapUp();
 		}
 
-		private void initAsignedPartitions() {
+		private void initAssignedPartitions() {
 			if (isRunning() && this.definedPartitions != null) {
 				try {
 					initPartitionsIfNeeded();

spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/FilteringBatchMessageListenerAdapter.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2016-2017 the original author or authors.
+ * Copyright 2016-2019 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -87,7 +87,7 @@ public void onMessage(List<ConsumerRecord<K, V>> consumerRecords, Acknowledgment
 		 */
 		if (consumerRecords.size() > 0 || consumerAware
 				|| (!this.ackDiscarded && this.delegateType.equals(ListenerType.ACKNOWLEDGING))) {
-			invokeDelagate(consumerRecords, acknowledgment, consumer);
+			invokeDelegate(consumerRecords, acknowledgment, consumer);
 		}
 		else {
 			if (this.ackDiscarded && acknowledgment != null) {
@@ -96,7 +96,7 @@ public void onMessage(List<ConsumerRecord<K, V>> consumerRecords, Acknowledgment
 		}
 	}
 
-	private void invokeDelagate(List<ConsumerRecord<K, V>> consumerRecords, Acknowledgment acknowledgment,
+	private void invokeDelegate(List<ConsumerRecord<K, V>> consumerRecords, Acknowledgment acknowledgment,
 			Consumer<?, ?> consumer) {
 		switch (this.delegateType) {
 			case ACKNOWLEDGING_CONSUMER_AWARE:

spring-kafka/src/main/java/org/springframework/kafka/support/serializer/ErrorHandlingDeserializer2.java

@@ -54,7 +54,7 @@ public class ErrorHandlingDeserializer2<T> implements Deserializer<T> {
 	public static final String KEY_DESERIALIZER_EXCEPTION_HEADER = KEY_DESERIALIZER_EXCEPTION_HEADER_PREFIX + "Key";
 
 	/**
-	 * Heaader name for deserialization exceptions.
+	 * Header name for deserialization exceptions.
 	 */
 	public static final String VALUE_DESERIALIZER_EXCEPTION_HEADER = KEY_DESERIALIZER_EXCEPTION_HEADER_PREFIX + "Value";
 

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2017-2018 the original author or authors.
+ * Copyright 2017-2019 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -377,7 +377,7 @@ public void testAbort() {
 	}
 
 	@Test
-	public void testExcecuteInTransactionNewInnerTx() {
+	public void testExecuteInTransactionNewInnerTx() {
 		@SuppressWarnings("unchecked")
 		Producer<Object, Object> producer1 = mock(Producer.class);
 		@SuppressWarnings("unchecked")
@@ -407,7 +407,7 @@ Producer<Object, Object> createTransactionalProducerForPartition() {
 		KafkaTransactionManager<Object, Object> tm = new KafkaTransactionManager<>(pf);
 
 		try {
-			TransactionSupport.setTransactionIdSuffix("testExcecuteInTransactionNewInnerTx");
+			TransactionSupport.setTransactionIdSuffix("testExecuteInTransactionNewInnerTx");
 			new TransactionTemplate(tm).execute(s -> {
 				return template.executeInTransaction(t -> {
 					template.sendDefault("foo", "bar");

spring-kafka/src/test/java/org/springframework/kafka/listener/RemainingRecordsErrorHandlerTests.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2019 the original author or authors.
+ * Copyright 2019-2019 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -81,7 +81,7 @@ public class RemainingRecordsErrorHandlerTests {
 	 */
 	@SuppressWarnings("unchecked")
 	@Test
-	public void remaingRecordsReceived() throws Exception {
+	public void remainingRecordsReceived() throws Exception {
 		assertThat(this.config.deliveryLatch.await(10, TimeUnit.SECONDS)).isTrue();
 		assertThat(this.config.commitLatch.await(10, TimeUnit.SECONDS)).isTrue();
 		assertThat(this.config.pollLatch.await(10, TimeUnit.SECONDS)).isTrue();