spring-projectsGH-2252: Applied code review

Author: frosiere

spring-kafka-docs/src/main/asciidoc/kafka.adoc

@@ -2471,6 +2471,10 @@ Useful when the consumer code cannot determine that an `ErrorHandlingDeserialize
 |`null`
 |When present and `syncCommits` is `false` a callback invoked after the commit completes.
 
+|[[offsetAndMetadataProvider]]<<offsetAndMetadataProvider,`offsetAndMetadataProvider`>>
+|`null`
+|A provider for `OffsetAndMetadata`; by default, the provider creates an offset and metadata with empty metadata. The provider gives a way to customize the metadata.
+
 |[[commitLogLevel]]<<commitLogLevel,`commitLogLevel`>>
 |DEBUG
 |The logging level for logs pertaining to committing offsets.

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

@@ -44,6 +44,7 @@
  * @param <V> the value type.
  *
  * @author Gary Russell
+ * @author Francois Rosiere
  *
  * @since 1.3.5
  *

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

@@ -17,17 +17,19 @@
 package org.springframework.kafka.listener;
 
 import org.springframework.lang.Nullable;
+import org.springframework.util.Assert;
 
 /**
  * Default implementation for {@link ListenerMetadata}.
  * @author Francois Rosiere
  * @since 2.8.6
  */
-public class DefaultListenerMetadata implements ListenerMetadata {
+class DefaultListenerMetadata implements ListenerMetadata {
 
 	private final MessageListenerContainer container;
 
-	public DefaultListenerMetadata(MessageListenerContainer container) {
+	DefaultListenerMetadata(MessageListenerContainer container) {
+		Assert.notNull(container, "'container' must not be null");
 		this.container = container;
 	}
 

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

@@ -47,6 +47,7 @@
  * fallback handler.
  *
  * @author Gary Russell
+ * @author Francois Rosiere
  * @since 2.8
  *
  */

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

@@ -144,6 +144,7 @@
  * @author Tom van den Berge
  * @author Lukasz Kaminski
  * @author Tomaz Fernandes
+ * @author Francois Rosiere
  */
 public class KafkaMessageListenerContainer<K, V> // NOSONAR line count
 		extends AbstractMessageListenerContainer<K, V> {

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

@@ -38,6 +38,7 @@
  * Listener utilities.
  *
  * @author Gary Russell
+ * @author Francois Rosiere
  * @since 2.0
  *
  */

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

@@ -36,6 +36,7 @@
  * @author Gary Russell
  * @author Vladimir Tsanev
  * @author Tomaz Fernandes
+ * @author Francois Rosiere
  */
 public interface MessageListenerContainer extends SmartLifecycle, DisposableBean {
 
@@ -199,7 +200,7 @@ default String getListenerId() {
 	 * Get arbitrary static information that will be added to the
 	 * {@link KafkaHeaders#LISTENER_INFO} header of all records.
 	 * @return the info.
-	 * @since 2.8.4
+	 * @since 2.8.6
 	 */
 	@Nullable
 	default byte[] getListenerInfo() {

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

@@ -44,6 +44,7 @@
  * Seek utilities.
  *
  * @author Gary Russell
+ * @author Francois Rosiere
  * @since 2.2
  *
  */

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

@@ -48,6 +48,7 @@
 
 /**
  * @author Gary Russell
+ * @author Francois Rosiere
  * @since 2.3.1
  *
  */

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

@@ -25,6 +25,7 @@
 
 /**
  * @author Gary Russell
+ * @author Francois Rosiere
  * @since 2.7.1
  *
  */