[
https://issues.apache.org/jira/browse/IGNITE-16586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikolay Izhikov updated IGNITE-16586:
-------------------------------------
Description:
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}
was:
Currently, only indexed parameters value can be provided for Cdc streamers.
We should support named parameters.
{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>
{code}
> 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)
