Commit aef9e18d by songyinghui

feat:好办kafka配置

parent 0872f0ff
...@@ -11,7 +11,7 @@ ...@@ -11,7 +11,7 @@
<bean id="consumerProperties-data" class="java.util.HashMap"> <bean id="consumerProperties-data" class="java.util.HashMap">
<constructor-arg> <constructor-arg>
<map> <map>
<entry key="bootstrap.servers" value="${kafka.service}"/> <entry key="bootstrap.servers" value="${kafka.data.service}"/>
<entry key="group.id" value="haoban-3-sync"/> <entry key="group.id" value="haoban-3-sync"/>
<entry key="key.deserializer" <entry key="key.deserializer"
value="org.apache.kafka.common.serialization.StringDeserializer"/> value="org.apache.kafka.common.serialization.StringDeserializer"/>
...@@ -37,7 +37,7 @@ ...@@ -37,7 +37,7 @@
<constructor-arg name="topics"> <constructor-arg name="topics">
<list> <list>
<!-- <value>${interact_record_topic}</value>--> <!-- <value>${interact_record_topic}</value>-->
<value>cms_mbr_bury_point</value> <value>${interact.record.topic}</value>
</list> </list>
</constructor-arg> </constructor-arg>
<property name="messageListener" ref="interactRecordMessageListener"/> <property name="messageListener" ref="interactRecordMessageListener"/>
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment