Skip to content

Commit bfc8bbe

Browse files
authored
Merge pull request #73 from marklogic-community/feature/class-fix
Making task classes public again
2 parents e12280a + 460dcf9 commit bfc8bbe

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/main/java/com/marklogic/kafka/connect/sink/BulkDataServicesSinkTask.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727
* to provide their own endpoint implementation, thus giving the user full control over how data is written to
2828
* MarkLogic.
2929
*/
30-
class BulkDataServicesSinkTask extends AbstractSinkTask {
30+
public class BulkDataServicesSinkTask extends AbstractSinkTask {
3131

3232
private DatabaseClient databaseClient;
3333
private InputCaller.BulkInputCaller<JsonNode> bulkInputCaller;

src/main/java/com/marklogic/kafka/connect/sink/WriteBatcherSinkTask.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323
/**
2424
* Uses MarkLogic's Data Movement SDK (DMSDK) to write data to MarkLogic.
2525
*/
26-
class WriteBatcherSinkTask extends AbstractSinkTask {
26+
public class WriteBatcherSinkTask extends AbstractSinkTask {
2727

2828
private DatabaseClient databaseClient;
2929
private DataMovementManager dataMovementManager;

0 commit comments

Comments
 (0)