DBZ-4450 small fix
This commit is contained in:
parent
32a94e34ca
commit
683bf1eaa2
@ -147,7 +147,6 @@ else if (record.value() instanceof byte[]) {
|
||||
deliveries.add(publisher.publish(pubsubMessage.build()));
|
||||
committer.markProcessed(record);
|
||||
}
|
||||
;
|
||||
List<String> messageIds;
|
||||
try {
|
||||
messageIds = ApiFutures.allAsList(deliveries).get();
|
||||
|
Loading…
Reference in New Issue
Block a user