1 <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
\r
2 xmlns:util="http://www.springframework.org/schema/util"
\r
4 http://www.springframework.org/schema/beans
\r
5 http://www.springframework.org/schema/beans/spring-beans.xsd
\r
6 http://www.springframework.org/schema/util
\r
7 http://www.springframework.org/schema/util/spring-util.xsd
\r
11 <bean id="eventConsumer" class="com.att.ecomp.event.client.KafkaEventConsumer" >
\r
12 <constructor-arg name="topic" value="mytopic" />
\r
13 <constructor-arg name="groupId" value="mygroupId" />
\r
14 <constructor-arg name="hosts" ref="hosts" />
\r
18 <bean id="eventPublisher" class="org.onap.aai.event.client.DMaaPEventPublisher">
\r
19 <constructor-arg name="host" value="mr.api.simpledemo.openecomp.org:3904" />
\r
20 <constructor-arg name="topic" value="SpikeRawEventsOnap" />
\r
21 <constructor-arg name="username" value="test" />
\r
22 <constructor-arg name="password" value="test" />
\r
23 <constructor-arg name="maxBatchSize" value="100" />
\r
24 <constructor-arg name="maxAgeMs" value="250" />
\r
25 <constructor-arg name="delayBetweenBatchesMs" value="50" />
\r
26 <constructor-arg name="transportType" value="HTTPAUTH" />
\r
29 <bean id="eventConsumer" class="org.onap.aai.event.client.DMaaPEventConsumer">
\r
30 <constructor-arg name="host" value="mr.api.simpledemo.openecomp.org:3904" />
\r
31 <constructor-arg name="topic" value="champRawEventsOnap" />
\r
32 <constructor-arg name="username" value="test" />
\r
33 <constructor-arg name="password" value="test" />
\r
34 <constructor-arg name="consumerGroup" value="spike-onap" />
\r
35 <constructor-arg name="consumerId" value="spike-onap" />
\r
36 <constructor-arg name="timeoutMs" value="1000" />
\r
37 <constructor-arg name="messageLimit" value="100" />
\r
38 <constructor-arg name="transportType" value="HTTPAUTH" />
\r
39 <constructor-arg name="protocol" value="http" />
\r
40 <constructor-arg name="filter">
\r
45 <bean id="spikeService" class="org.onap.aai.spike.service.SpikeService" init-method="startup">
\r
46 <constructor-arg ref="eventConsumer" />
\r
47 <constructor-arg ref="eventPublisher" />
\r