gobblin-core-base/src/main/java/org/apache/gobblin/writer/BufferedAsyncDataWriter.java
gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/writer/Kafka08DataWriter.java

gobblin-core-base/src/main/java/org/apache/gobblin/writer/BufferedAsyncDataWriter.java
gobblin-modules/gobblin-kafka-1/src/main/java/org/apache/gobblin/kafka/writer/Kafka1DataWriter.java

gobblin-core-base/src/main/java/org/apache/gobblin/writer/BufferedAsyncDataWriter.java
gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/Kafka09DataWriter.java

gobblin-core-base/src/main/java/org/apache/gobblin/writer/Batch.java
gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AsyncHttpWriter.java

gobblin-core-base/src/main/java/org/apache/gobblin/writer/FutureWrappedWriteCallback.java
gobblin-modules/gobblin-couchbase/src/main/java/org/apache/gobblin/couchbase/writer/CouchbaseWriter.java

gobblin-core-base/src/main/java/org/apache/gobblin/writer/FutureWrappedWriteCallback.java
gobblin-modules/gobblin-elasticsearch/src/main/java/org/apache/gobblin/elasticsearch/writer/FutureCallbackHolder.java

gobblin-core-base/src/main/java/org/apache/gobblin/writer/AcknowledgableWatermark.java
gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/GlobalMetadata.java