I am relatively new to camel, but until you get more experienced replies, I'd suggest your second path (replaceFromWith) but use something like seda:mockKafka - then send your test messages to seda:mockKafka. I'm under the impression that a mock can't produce a message, which is why you're getting the UnsupportedOperationException.
-Steve > -----Original Message----- > From: ganga_camel [mailto:ganga...@gmail.com] > Sent: Friday, June 10, 2016 7:59 AM > To: users@camel.apache.org > Subject: How to Mock Kafka Consumer Endpoint with Spock Framework Unit > Test cases > > Hi, > > I am using Spock Framework to perform Unit Testing of Camel Routes. My > first route consumes from Kafka Consumer Endpoint. I need to mock this end > point and send the message to mock endpoint as part of the unit testing, > below is how I have tried > > camelctx.getRouteDefinitions().get(0).adviceWith(camelctx, new > AdviceWithRouteBuilder() { > @Override > void configure() throws Exception { > > interceptSendToEndpoint("kafka:{{server}}?topic={{topic}}&zookeeperHost > ={{zookeeper}}&zookeeperPort={{zookeeperport}}&groupId={{group}}&aut > oCommitEnable=true&autoOffsetReset=smallest&autoCommitIntervalMs=1 > 000") > .skipSendToOriginalEndpoint() > .to("mock:kafkaCon") > } > }) > > Here I get the error "java.lang.NullPointerException: Cannot invoke method > getIn() on null object" . > > I have also tried > camelctx.getRouteDefinitions().get(0).adviceWith(camelctx, new > AdviceWithRouteBuilder() { > @Override > void configure() throws Exception { > replaceFromWith("mock:kafkaCon") > } > }) > I get the error "java.lang.UnsupportedOperationException: You cannot > consume from this endpoint" > > Any suggession on how to Mock the Kafka Consumer endpoint and advise if I > am trying to do it wrong.. > > -Ganga > > > > -- > View this message in context: http://camel.465427.n5.nabble.com/How-to- > Mock-Kafka-Consumer-Endpoint-with-Spock-Framework-Unit-Test-cases- > tp5783856.html > Sent from the Camel - Users mailing list archive at Nabble.com.
