[
https://issues.apache.org/jira/browse/IGNITE-16586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikolay Izhikov resolved IGNITE-16586.
--------------------------------------
Resolution: Fixed
> Provide named parameters for Cdc streamers
> ------------------------------------------
>
> Key: IGNITE-16586
> URL: https://issues.apache.org/jira/browse/IGNITE-16586
> Project: Ignite
> Issue Type: Improvement
> Reporter: Nikolay Izhikov
> Priority: Minor
> Labels: IEP-59, ise
>
> Currently, only indexed parameters value can be provided for Cdc streamers.
> We should support named parameters.
> IgniteToIgniteCdcStreamer
> {code}
> <bean id="cdc.streamer"
> class="org.apache.ignite.cdc.IgniteToIgniteCdcStreamer">
> <constructor-arg index="0">
> <bean class="org.apache.ignite.configuration.IgniteConfiguration">
> <property name="igniteInstanceName"
> value="ignite-2029-cdc-client" />
> <property name="clientMode" value="true" />
> <property name="peerClassLoadingEnabled" value="true" />
> <property name="localHost" value="127.0.0.1" />
> <property name="discoverySpi">
> <bean
> class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
> <property name="localPort" value="47600" />
> <property name="ipFinder">
> <bean
> class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
> <property name="addresses"
> value="127.0.0.1:47600..47610" />
> </bean>
> </property>
> <property name="joinTimeout" value="10000" />
> </bean>
> </property>
> </bean>
> </constructor-arg>
> <constructor-arg index="1" value="false" />
> <constructor-arg index="2">
> <util:list>
> <bean class="java.lang.String">
> <constructor-arg type="String" value="terminator" />
> </bean>
> </util:list>
> </constructor-arg>
> <constructor-arg index="3" value="256" />
> </bean>
> <bean id="cdc.streamer"
> class="org.apache.ignite.cdc.kafka.IgniteToKafkaCdcStreamer">
> <constructor-arg name="topic" value="ignite" />
> <constructor-arg name="kafkaParts" value="16" />
> <constructor-arg name="caches">
> <util:list>
> <bean class="java.lang.String">
> <constructor-arg type="String"
> value="terminator" />
> </bean>
> </util:list>
> </constructor-arg>
> <constructor-arg name="maxBatchSize" value="256" />
> <constructor-arg name="onlyPrimary" value="false" />
> <constructor-arg name="kafkaProps"
> ref="kafkaProperties" />
> </bean>
> {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
