Exception while pushing Avro messages into Kafka

[Praveen . A]

Hello Experts,

We are trying to push Avro formatted message into Kafka through Camel and 
caught with below exception so couldn't succeeded further.

I have attached the complete source code along with pom.xml file for version 
details.

Please let us know the best way of pushing Avro messages into Kafka through 
camel integration.

15/09/08 16:43:21 INFO utils.VerifiableProperties: Verifying properties
15/09/08 16:43:21 INFO utils.VerifiableProperties: Property 
metadata.broker.list is overridden to edelx0002:9092
15/09/08 16:43:21 INFO utils.VerifiableProperties: Property partitioner.class 
is overridden to kafka.producer.DefaultPartitioner
15/09/08 16:43:21 INFO utils.VerifiableProperties: Property 
request.required.acks is overridden to 0
15/09/08 16:43:21 INFO utils.VerifiableProperties: Property serializer.class is 
overridden to kafka.serializer.DefaultEncoder
Exception in thread "main" java.lang.NullPointerException
       at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:67)
       at org.apache.camel.impl.MessageSupport.getBody(MessageSupport.java:47)
       at 
org.apache.camel.component.kafka.KafkaProducer.process(KafkaProducer.java:72)
       at 
com.tgt.stores.CamelAvroProducer.processItemMessage(CamelAvroProducer.java:145)
       at com.tgt.stores.TestProducer.main(TestProducer.java:12)


Regards,
Praveen

<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";>
  <modelVersion>4.0.0</modelVersion>
  <groupId>EDE</groupId>
  <artifactId>com.tgt.stores</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <name>com.tgt.stores</name>
  <dependencies>
		<dependency>
			<groupId>org.apache.camel</groupId>
			<artifactId>camel-core</artifactId>
			<version>2.10.1</version>
		</dependency>
		<dependency>
			<groupId>org.apache.camel</groupId>
			<artifactId>camel-spring</artifactId>
			<version>2.10.1</version>
		</dependency>

		<dependency>
			<groupId>org.apache.activemq</groupId>
			<artifactId>activemq-camel</artifactId>
			<version>5.6.0</version>
		</dependency>

		<dependency>
			<groupId>org.apache.activemq</groupId>
			<artifactId>activemq-pool</artifactId>
			<version>5.6.0</version>
		</dependency>

        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-ftp</artifactId>
            <version>2.10.1</version>
        </dependency>

		<dependency>
			<groupId>log4j</groupId>
			<artifactId>log4j</artifactId>
			<version>1.2.16</version>
		</dependency>

		<dependency>
			<groupId>org.slf4j</groupId>
			<artifactId>slf4j-log4j12</artifactId>
			<version>1.6.4</version>
		</dependency>

		<dependency>
			<groupId>org.apache.avro</groupId>
			<artifactId>avro</artifactId>
			<version>1.7.7</version>
		</dependency>
		<dependency>
  		<groupId>org.apache.kafka</groupId>
  		<artifactId>kafka_2.10</artifactId>
  		<version>0.8.2.1</version>
  	</dependency>
		<dependency>
			<groupId>org.apache.camel</groupId>
			<artifactId>camel-kafka</artifactId>
			<version>2.15.1</version>
		</dependency>
  </dependencies>
 
      
</project>