in src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java [203:205]
public int getTaskId() { return taskId; }