public AsyncDataWriter getAsyncDataWriter ( Properties properties ) { EventhubDataWriter eventhubDataWriter = new EventhubDataWriter ( properties ) ; EventhubBatchAccumulator accumulator = new EventhubBatchAccumulator ( properties ) ; BatchedEventhubDataWriter batchedEventhubDataWriter = new BatchedEventhubDataWriter ( accumulator , eventhubDataWriter ) ; return batchedEventhubDataWriter ; }
Create an eventhub data writer wrapped into a buffered async data writer