From dba3011c534c8297297dce204e8fbd2c8fcb54d9 Mon Sep 17 00:00:00 2001 From: dilini-muthumala Date: Fri, 12 Jul 2019 18:25:59 +0530 Subject: [PATCH] Rename topic.offset.map to topic.offsets.map --- .../java/io/siddhi/extension/io/kafka/source/KafkaSource.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/component/src/main/java/io/siddhi/extension/io/kafka/source/KafkaSource.java b/component/src/main/java/io/siddhi/extension/io/kafka/source/KafkaSource.java index ad5ac8b3..3053dc8c 100644 --- a/component/src/main/java/io/siddhi/extension/io/kafka/source/KafkaSource.java +++ b/component/src/main/java/io/siddhi/extension/io/kafka/source/KafkaSource.java @@ -102,7 +102,7 @@ type = {DataType.BOOL}, optional = true, defaultValue = "false"), - @Parameter(name = "topic.offset.map", + @Parameter(name = "topic.offsets.map", description = "This parameter specifies reading offsets for each topic and partition. " + "The value for this parameter is specified in the following format: \n " + "`=,=,`\n " + @@ -171,7 +171,7 @@ public class KafkaSource extends Source implements public static final String ADAPTOR_SUBSCRIBER_ZOOKEEPER_CONNECT_SERVERS = "bootstrap.servers"; public static final String ADAPTOR_SUBSCRIBER_PARTITION_NO_LIST = "partition.no.list"; public static final String ADAPTOR_OPTIONAL_CONFIGURATION_PROPERTIES = "optional.configuration"; - public static final String TOPIC_OFFSET_MAP = "topic.offset.map"; + public static final String TOPIC_OFFSET_MAP = "topic.offsets.map"; public static final String THREADING_OPTION = "threading.option"; public static final String SEQ_ENABLED = "seq.enabled"; public static final String HEADER_SEPARATOR = ",";