Druid Tranquilty - duplicate messages

kafka.json

{
  "dataSources" : {
    "totals-v2" : {
      "spec" : {
        "dataSchema" : {
          "dataSource" : "totals-v2",
          "parser" : {
            "type" : "string",
            "parseSpec" : {
              "timestampSpec" : {
                "column" : "dateTime",
                "format" : "auto"
              },
              "dimensionsSpec" : {
                "dimensions" : ["campaignId"],
                "dimensionExclusions" : [
                  "dateTime"
                ]
              },
              "format" : "json"
            }
          },
          "granularitySpec" : {
            "type" : "uniform",
            "segmentGranularity" : "HOUR",
            "queryGranularity" : "none"
          },
          "metricsSpec" : [
            {"type" : "longSum", "name" : "totalCount", "fieldName" : "countDelta"}
           ,{"type" : "doubleSum", "name" : "price", "fieldName" : "priceDelta"}
          ]
        },
        "tuningConfig" : {
          "type" : "realtime",
          "maxRowsInMemory" : "100000",
          "intermediatePersistPeriod" : "PT30m",
          "windowPeriod" : "PT3h"
        }
      },
      "properties" : {
        "task.partitions" : "1",
        "task.replicants" : "2",
        "topicPattern" : "Totals-v2"
      }
    }
  },
  "properties" : {
    "zookeeper.connect" : "zoo-101:2181,zoo-102:2181,zoo-103:2181/druid_v2",
    "druid.discovery.curator.path" : "/discovery",
    "druid.selectors.indexing.serviceName" : "druid/overlord",
    "commit.periodMillis" : "15000",
    "consumer.numThreads" : "2",
    "kafka.zookeeper.connect" : "zoo-101:2181,zoo-102:2181,zoo-103:2181/Kafka_v0_8_2_1",
    "kafka.group.id" : "tranquility-kafka",
    "kafka.fetch.message.max.bytes" : "1048586",
    "kafka.auto.offset.reset": "largest"
  }
}