com.github.jcustenborder.kafka.connect.utils.config

Class TaskConfigs

java.lang.Object

com.github.jcustenborder.kafka.connect.utils.config.TaskConfigs

public class TaskConfigs
extends Object

Constructor Summary

Constructors

Constructor and Description
TaskConfigs()

Method Summary

Modifier and Type	Method and Description
static List<Map<String,String>>	multiple(Map<String,String> settings, int taskCount) Method is used to generate a list of taskConfigs based on the supplied settings.
static List<Map<String,String>>	single(Map<String,String> settings) Method will create a single from the supplied settings.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskConfigs

public TaskConfigs()

Method Detail

single

public static List<Map<String,String>> single(Map<String,String> settings)

Method will create a single from the supplied settings.

Parameters:

settings -

Returns:

multiple

public static List<Map<String,String>> multiple(Map<String,String> settings,
                                                int taskCount)

Method is used to generate a list of taskConfigs based on the supplied settings.

Parameters:

settings -

taskCount -

Returns: