i am facing integrating divolte-collector with kafka

[karthik07github]

I have successfully installed divolte-collector 0.90v package ..
But i am facing problem for integrating divolte-collector with kafka 2.0.

i am getting error as show below
ERROR Closing socket for /127.0.0.1 because of error (kafka.network.Processor)
kafka.common.KafkaException: Wrong request type 18
at kafka.api.RequestKeys$.deserializerForKey(RequestKeys.scala:57)
at kafka.network.RequestChannel$Request.(RequestChannel.scala:53)
at kafka.network.Processor.read(SocketServer.scala:353)
at kafka.network.Processor.run(SocketServer.scala:245)
at java.lang.Thread.run(Thread.java:748)

please let me know what changes to be done and here is my divolte-config setting as show below.

divolte {
global {
kafka {
// Enable Kafka flushing
enabled = true

  // The properties under the producer key in this
  // configuration are used to create a Properties object
  // which is passed to Kafka as is. At the very least,
  // configure the broker list here. For more options
  // that can be passed to a Kafka producer, see this link:
  // http://kafka.apache.org/082/documentation.html#newproducerconfigs
  producer = {
    bootstrap.servers = "localhost:9092"
  }
}

}

sinks {
// The name of the sink. (It's referred to by the mapping.)
my_sink = {
type = kafka

  // This is the name of the topic that data will be produced on
  topic = divolte-data

}
}

mappings {
my_mapping = {
schema_file = "/home/karthik/Documents/divolte-collector-0.9.0/bin/MyEventRecord.avsc"
mapping_script_file = "/home/karthik/Documents/divolte-collector-0.9.0/bin/mapping.groovy"
sources = [browser]
sinks = [my_sink]
}
}
}