Hi Mohan/Lasantha
I get the below java.lang.NoClassDefFoundError:
kafka/producer/ProducerConfig when sending a request to a kifka output
adaptor. I started the zookeeper, 2 broakers and also created a topic
in kafka called testTopic.
Is their additional configurations needed when using kafka output adaptor
[2014-03-15 14:27:29,810] ERROR - {QueueWorker} Error in passing
event eventList [
Event{
streamId='localstream:1.0.0',
timeStamp=1394873849763,
metaData=[-1234, , , , , application/edi-hl7, , ,
shavantha-ThinkPad-T530.local:9766],
correlationData=[415592839887431747309],
payloadData=[IN, HL7ToBAM, mediate,
urn:uuid:E99ED42E77EFEF6AD61394873849067, 1394873849761],
arbitraryDataMap=null,
}
] to subscriber
org.wso2.carbon.event.input.adaptor.wso2event.WSO2EventEventAdaptorType$AgentTransportCallback@1083899
java.lang.NoClassDefFoundError: kafka/producer/ProducerConfig
at
org.wso2.carbon.event.output.adaptor.kafka.KafkaEventAdaptorType.publish(KafkaEventAdaptorType.java:109)
at
org.wso2.carbon.event.output.adaptor.core.AbstractOutputEventAdaptor.publishCall(AbstractOutputEventAdaptor.java:123)
at
org.wso2.carbon.event.output.adaptor.core.internal.CarbonOutputEventAdaptorService.publish(CarbonOutputEventAdaptorService.java:89)
at
org.wso2.carbon.event.formatter.core.config.EventFormatter.sendEventData(EventFormatter.java:179)
at
org.wso2.carbon.event.formatter.core.EventFormatterSender.sendEventData(EventFormatterSender.java:36)
at
org.wso2.carbon.event.processor.core.internal.listener.ExternalStreamConsumer.consumeEvent(ExternalStreamConsumer.java:53)
at
org.wso2.carbon.event.processor.core.internal.stream.EventJunction.dispatchEvent(EventJunction.java:65)
at
org.wso2.carbon.event.processor.core.internal.listener.ExternalStreamListener.onEvent(ExternalStreamListener.java:35)
at
org.wso2.carbon.event.builder.core.internal.config.StreamEventJunction.dispatchEvent(StreamEventJunction.java:104)
at
org.wso2.carbon.event.builder.core.internal.EventBuilder.sendEvent(EventBuilder.java:249)
at
org.wso2.carbon.event.builder.core.internal.EventBuilder.processTypedEvent(EventBuilder.java:235)
at
org.wso2.carbon.event.builder.core.internal.EventBuilder$TypedEventListenerImpl.onEvent(EventBuilder.java:312)
at
org.wso2.carbon.event.input.adaptor.core.InputEventAdaptorListener.onEventCall(InputEventAdaptorListener.java:98)
at
org.wso2.carbon.event.input.adaptor.wso2event.WSO2EventEventAdaptorType$AgentTransportCallback.receive(WSO2EventEventAdaptorType.java:274)
at
org.wso2.carbon.databridge.core.internal.queue.QueueWorker.run(QueueWorker.java:81)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)
Caused by: java.lang.ClassNotFoundException: kafka.producer.ProducerConfig
at
org.eclipse.osgi.internal.loader.BundleLoader.findClassInternal(BundleLoader.java:501)
at
org.eclipse.osgi.internal.loader.BundleLoader.findClass(BundleLoader.java:421)
at
org.eclipse.osgi.internal.loader.BundleLoader.findClass(BundleLoader.java:412)
at
org.eclipse.osgi.internal.baseadaptor.DefaultClassLoader.loadClass(DefaultClassLoader.java:107)
at java.lang.ClassLoader.loadClass(ClassLoader.java:247)
... 21 more
Shavantha Weerasinghe
Senior Software Engineer QA
WSO2, Inc.
lean.enterprise.middleware.
http://wso2.com
http://wso2.org
Tel : 94 11 214 5345
Fax :94 11 2145300
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev
