Skip to content

Commit 9624580

Browse files
authored
fix: update for newest BuffererProducer interface (#71)
1 parent 7ec32e8 commit 9624580

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -116,15 +116,15 @@ HRecord hRecord = HRecord.newBuilder()
116116
CompletableFuture<RecordId> future = producer.write(hRecord);
117117

118118
// buffered writes
119-
Producer batchedProducer = client.newProducer()
119+
BufferedProducer batchedProducer = client.newBufferedProducer()
120120
.stream("test_stream")
121-
.enableBatch()
122121
.recordCountLimit(100)
123122
.build();
124123
for(int i = 0; i < 1000; ++i) {
125124
random.nextBytes(rawRecord);
126125
batchedProducer.write(rawRecord);
127126
}
127+
batchedProducer.close();
128128

129129

130130
```

0 commit comments

Comments
 (0)