Hi Yunze,

Yunze Xu <y...@streamnative.io.invalid> 于2022年11月10日周四 20:17写道:

> ```java
> Map<String, CompletableFuture<Void>> seekAsync(Map<String, MessageId>
> messageIdMap);
> Map<String, CompletableFuture<Void>> acknowledgeAsync(Map<String,
> MessageId> messageIdMap);
> Map<String, CompletableFuture<Void>>
> acknowledgeCumulativeAsync(Map<String, MessageId> messageIdMap);
> ```
why not add the method using `String topicName directly, MessageId
msgId` directly?
like:
```
CompletableFuture<Void> seekAsync(String topicName, MessageId msgId);
CompletableFuture<Void> acknowledgeAsync(String topicName, MessageId msgId);
CompletableFuture<Void> acknowledgeCumulativeAsync(String topicName,
MessageId msgId);
```
it is more simple and easy to understand. otherwise, we need to add the method
```
Map<String, List<CompletableFuture<Void>>>
acknowledgeAsync(Map<String, List< MessageId>> messageIdMap);
```

Reply via email to