Hi again!
I understand the issue of the topics but at the first i don't need it.
I return an empty list in the getInputMessageProperties like you have told
me:
*@Override
protected List<Property> getInputMessageProperties() {
List<Property> propertyList = new ArrayList<Property>();
return propertyList;
}*
and the method subscribe is similar than i used in the wso cep 2.1.0:
* public String subscribe(
InputEventAdaptorMessageConfiguration
inputEventAdaptorMessageConfiguration,
InputEventAdaptorListener inputEventAdaptorListener,
InputEventAdaptorConfiguration inputEventAdaptorConfiguration,
AxisConfiguration axisConfiguration) {
Map<String, String> brokerProperties = new HashMap<String,
String>();
brokerProperties.putAll(inputEventAdaptorConfiguration.getInputProperties());
String zkConnect =
brokerProperties.get(ConsumerKafkaConstants.BROKER_SUSCRIBER_ZOOKEEPER_CONNECT);
String topic =
brokerProperties.get(ConsumerKafkaConstants.BROKER_SUSCRIBER_TOPIC);
String groupID =
brokerProperties.get(ConsumerKafkaConstants.BROKER_SUSCRIBER_GROUP_ID);
String threadsStr =
brokerProperties.get(ConsumerKafkaConstants.BROKER_SUSCRIBER_THREADS);
int threads = Integer.parseInt(threadsStr);
consumerRedBorder = new ConsumerKafkaRedBorder(zkConnect, groupID,
topic,
ConsumerKafkaType.createConsumerConfig(zkConnect, groupID));
consumerRedBorder.run(threads, inputEventAdaptorListener);
return null;
}*
But the exception is still jumping! :S
Have I do something with inputEventAdaptorMessageConfiguration????
Thanks.
Andrés Gómez!
--
View this message in context:
http://wso2-oxygen-tank.10903.n7.nabble.com/Dev-wso2-cep-3-0-0-Event-Builder-Problem-tp87891p87927.html
Sent from the WSO2 Development mailing list archive at Nabble.com.
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev
