@@ -281,26 +281,26 @@ private void checkK2IMetrics(Function<String, Long> longMetric) {
281281 * @return Future for Change Data Capture application.
282282 */
283283 protected IgniteInternalFuture <?> igniteToKafka (
284- IgniteConfiguration igniteCfg ,
285- String topic ,
286- String metadataTopic ,
287- String cache ,
288- Set <String > includeTemplates ,
289- Set <String > excludeTemplates ,
290- String threadName
284+ IgniteConfiguration igniteCfg ,
285+ String topic ,
286+ String metadataTopic ,
287+ String cache ,
288+ Set <String > includeTemplates ,
289+ Set <String > excludeTemplates ,
290+ String threadName
291291 ) {
292292 return runAsync (() -> {
293293 IgniteToKafkaCdcStreamer cdcCnsmr = new IgniteToKafkaCdcStreamer ()
294- .setTopic (topic )
295- .setMetadataTopic (metadataTopic )
296- .setKafkaPartitions (DFLT_PARTS )
297- .setCaches (Collections .singleton (cache ))
298- .setIncludeTemplates (includeTemplates )
299- .setExcludeTemplates (excludeTemplates )
300- .setMaxBatchSize (KEYS_CNT )
301- .setOnlyPrimary (false )
302- .setKafkaProperties (kafkaProperties ())
303- .setKafkaRequestTimeout (DFLT_KAFKA_REQ_TIMEOUT );
294+ .setTopic (topic )
295+ .setMetadataTopic (metadataTopic )
296+ .setKafkaPartitions (DFLT_PARTS )
297+ .setCaches (Collections .singleton (cache ))
298+ .setIncludeTemplates (includeTemplates )
299+ .setExcludeTemplates (excludeTemplates )
300+ .setMaxBatchSize (KEYS_CNT )
301+ .setOnlyPrimary (false )
302+ .setKafkaProperties (kafkaProperties ())
303+ .setKafkaRequestTimeout (DFLT_KAFKA_REQ_TIMEOUT );
304304
305305 CdcConfiguration cdcCfg = new CdcConfiguration ();
306306
0 commit comments