[IGNITE-16586] Provide named parameters for Cdc streamers

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 2.13
• Labels: IEP-59 ise
• Assignee: Unassigned
• Reporter: Nikolay Izhikov
• Created: 18/Feb/22 15:53
• Updated: 29/Mar/22 08:22
• Resolved: 01/Mar/22 14:49

Description

Currently, only indexed parameters value can be provided for Cdc streamers.
We should support named parameters.

IgniteToIgniteCdcStreamer

    <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>

Issue Links

• is a clone of: IGNITE-16176 Configurable request timeouts in KafkaToIgniteCdcStreamerApplier and IgniteToKafkaCdcStreamer
• is fixed by: IGNITE-16176 Configurable request timeouts in KafkaToIgniteCdcStreamerApplier and IgniteToKafkaCdcStreamer