src/main/java/org/embulk/output/kafka/KafkaOutputPlugin.java in embulk-output-kafka-0.1.2 vs src/main/java/org/embulk/output/kafka/KafkaOutputPlugin.java in embulk-output-kafka-0.1.3

@@ -113,9 +113,13 @@
         public Map<String, String> getOtherProducerConfigs();
 
         @Config("ignore_columns")
         @ConfigDefault("[]")
         public List<String> getIgnoreColumns();
+
+        @Config("value_subject_name_strategy")
+        @ConfigDefault("null")
+        public Optional<String> getValueSubjectNameStrategy();
     }
 
     private static ObjectMapper objectMapper = new ObjectMapper();
     private Logger logger = LoggerFactory.getLogger(getClass());