Make kafkaTemplate protected in KafkaItemWriter

Issue #3802

Author: adityausathe

spring-batch-infrastructure/src/main/java/org/springframework/batch/item/kafka/KafkaItemWriter.java

@@ -33,7 +33,7 @@
  */
 public class KafkaItemWriter<K, T> extends KeyValueItemWriter<K, T> {
 
-	private KafkaTemplate<K, T> kafkaTemplate;
+	protected KafkaTemplate<K, T> kafkaTemplate;
 
 	@Override
 	protected void writeKeyValue(K key, T value) {

spring-batch-infrastructure/src/test/java/org/springframework/batch/item/kafka/KafkaItemWriterTests.java

@@ -103,6 +103,19 @@ public void testBasicDelete() throws Exception {
 		verify(this.kafkaTemplate).sendDefault(items.get(1), null);
 	}
 
+	@Test
+	public void testKafkaTemplateCanBeReferencedFromSubclass() {
+		KafkaItemWriter<String, String> kafkaItemWriter = new KafkaItemWriter<String, String>() {
+			@Override
+			protected void writeKeyValue(String key, String value) {
+				this.kafkaTemplate.sendDefault(key, value);
+			}
+		};
+		kafkaItemWriter.setKafkaTemplate(kafkaTemplate);
+		kafkaItemWriter.writeKeyValue("k", "v");
+		verify(kafkaTemplate).sendDefault("k", "v");
+	}
+
 	static class KafkaItemKeyMapper implements Converter<String, String> {
 
 		@Override