maksaska commented on code in PR #285: URL: https://github.com/apache/ignite-extensions/pull/285#discussion_r1958568270
########## modules/cdc-ext/examples/config/cdc-start-up/cdc-base-configuration.xml: ########## @@ -0,0 +1,83 @@ +<beans xmlns="http://www.springframework.org/schema/beans"; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xmlns:util="http://www.springframework.org/schema/util"; + xmlns:context="http://www.springframework.org/schema/context"; + xsi:schemaLocation=" + http://www.springframework.org/schema/beans + http://www.springframework.org/schema/beans/spring-beans.xsd + http://www.springframework.org/schema/util + http://www.springframework.org/schema/util/spring-util.xsd + http://www.springframework.org/schema/context + http://www.springframework.org/schema/context/spring-context-3.0.xsd";> + + <import resource="${cdc_streamer_xml_file_name}"/> + + <context:property-placeholder location="file:${ignite_properties_path}/ignite-cdc.properties"/> + + <!--IgniteConfiguration for source cluster connection--> + <bean class="org.apache.ignite.configuration.IgniteConfiguration"> + <property name="igniteInstanceName" value="${server_instance_name}"/> + <property name="consistentId" value="${server_instance_name}"/> + <property name="localHost" value="${server_host}"/> + <property name="discoverySpi" ref="ignTcpDiscoverySpi"/> + <property name="dataStorageConfiguration" ref="ignDataStorageConfiguration"/> + <property name="pluginProviders" ref="ignCacheVersionConflictResolverPluginProvider"/> + <property name="cacheConfiguration" ref="ignCacheConfiguration"/> + <property name="clientConnectorConfiguration" ref="ignClientConnectorConfiguration"/> + </bean> + + <!--CdcConfiguration--> + <bean id="cdc.cfg" class="org.apache.ignite.cdc.CdcConfiguration"> + <property name="consumer" ref="cdc.streamer"/> + </bean> + + <!--IgniteConfiguration property declaration--> + + <!--TcpDiscoverySpi--> + <bean id="ignTcpDiscoverySpi" class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> + <property name="ipFinder"> + <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder"> + <property name="addresses" value="${server_host}:${server_port_range}"/> + </bean> + </property> + + <property name="localPort" value="${server_local_port}"/> + <property name="joinTimeout" value="10000"/> + </bean> + + <!--DataStorageConfiguration--> + <bean id="ignDataStorageConfiguration" class="org.apache.ignite.configuration.DataStorageConfiguration"> + <property name="defaultDataRegionConfiguration"> + <bean class="org.apache.ignite.configuration.DataRegionConfiguration"> + <property name="cdcEnabled" value="true"/> + </bean> + </property> + + <property name="walForceArchiveTimeout" value="5000"/> + </bean> + + <!--CacheVersionConflictResolverPluginProvider--> + <bean id="ignCacheVersionConflictResolverPluginProvider" class="org.apache.ignite.cdc.conflictresolve.CacheVersionConflictResolverPluginProvider"> + <property name="caches"> + <set> + <value>terminator</value> + </set> + </property> + + <property name="clusterId" value="${cluster_id}"/> + <property name="conflictResolveField" value="val2"/> Review Comment: Yeah. In the script we use it ass version field of value JSON, that is pushed to the source cluster ########## modules/cdc-ext/examples/config/cdc-start-up/cdc-base-configuration.xml: ########## @@ -0,0 +1,83 @@ +<beans xmlns="http://www.springframework.org/schema/beans"; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xmlns:util="http://www.springframework.org/schema/util"; + xmlns:context="http://www.springframework.org/schema/context"; + xsi:schemaLocation=" + http://www.springframework.org/schema/beans + http://www.springframework.org/schema/beans/spring-beans.xsd + http://www.springframework.org/schema/util + http://www.springframework.org/schema/util/spring-util.xsd + http://www.springframework.org/schema/context + http://www.springframework.org/schema/context/spring-context-3.0.xsd";> + + <import resource="${cdc_streamer_xml_file_name}"/> + + <context:property-placeholder location="file:${ignite_properties_path}/ignite-cdc.properties"/> + + <!--IgniteConfiguration for source cluster connection--> + <bean class="org.apache.ignite.configuration.IgniteConfiguration"> + <property name="igniteInstanceName" value="${server_instance_name}"/> + <property name="consistentId" value="${server_instance_name}"/> + <property name="localHost" value="${server_host}"/> + <property name="discoverySpi" ref="ignTcpDiscoverySpi"/> + <property name="dataStorageConfiguration" ref="ignDataStorageConfiguration"/> + <property name="pluginProviders" ref="ignCacheVersionConflictResolverPluginProvider"/> + <property name="cacheConfiguration" ref="ignCacheConfiguration"/> + <property name="clientConnectorConfiguration" ref="ignClientConnectorConfiguration"/> + </bean> + + <!--CdcConfiguration--> + <bean id="cdc.cfg" class="org.apache.ignite.cdc.CdcConfiguration"> + <property name="consumer" ref="cdc.streamer"/> + </bean> + + <!--IgniteConfiguration property declaration--> + + <!--TcpDiscoverySpi--> + <bean id="ignTcpDiscoverySpi" class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> + <property name="ipFinder"> + <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder"> + <property name="addresses" value="${server_host}:${server_port_range}"/> + </bean> + </property> + + <property name="localPort" value="${server_local_port}"/> + <property name="joinTimeout" value="10000"/> + </bean> + + <!--DataStorageConfiguration--> + <bean id="ignDataStorageConfiguration" class="org.apache.ignite.configuration.DataStorageConfiguration"> + <property name="defaultDataRegionConfiguration"> + <bean class="org.apache.ignite.configuration.DataRegionConfiguration"> + <property name="cdcEnabled" value="true"/> + </bean> + </property> + + <property name="walForceArchiveTimeout" value="5000"/> + </bean> + + <!--CacheVersionConflictResolverPluginProvider--> + <bean id="ignCacheVersionConflictResolverPluginProvider" class="org.apache.ignite.cdc.conflictresolve.CacheVersionConflictResolverPluginProvider"> + <property name="caches"> + <set> + <value>terminator</value> + </set> + </property> + + <property name="clusterId" value="${cluster_id}"/> + <property name="conflictResolveField" value="val2"/> Review Comment: Yeah. In the script we use it as version field of value JSON, that is pushed to the source cluster -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: notifications-unsubscr...@ignite.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
