Package | Description |
---|---|
com.oracle.bmc.streaming | |
com.oracle.bmc.streaming.responses |
Modifier and Type | Method and Description |
---|---|
ConsumerCommitResponse |
StreamClient.consumerCommit(ConsumerCommitRequest request) |
ConsumerCommitResponse |
Stream.consumerCommit(ConsumerCommitRequest request)
Provides a mechanism to manually commit offsets, if not using commit-on-get consumer
semantics.
|
Modifier and Type | Method and Description |
---|---|
Future<ConsumerCommitResponse> |
StreamAsyncClient.consumerCommit(ConsumerCommitRequest request,
AsyncHandler<ConsumerCommitRequest,ConsumerCommitResponse> handler) |
Future<ConsumerCommitResponse> |
StreamAsync.consumerCommit(ConsumerCommitRequest request,
AsyncHandler<ConsumerCommitRequest,ConsumerCommitResponse> handler)
Provides a mechanism to manually commit offsets, if not using commit-on-get consumer
semantics.
|
Modifier and Type | Method and Description |
---|---|
Future<ConsumerCommitResponse> |
StreamAsyncClient.consumerCommit(ConsumerCommitRequest request,
AsyncHandler<ConsumerCommitRequest,ConsumerCommitResponse> handler) |
Future<ConsumerCommitResponse> |
StreamAsync.consumerCommit(ConsumerCommitRequest request,
AsyncHandler<ConsumerCommitRequest,ConsumerCommitResponse> handler)
Provides a mechanism to manually commit offsets, if not using commit-on-get consumer
semantics.
|
Modifier and Type | Method and Description |
---|---|
ConsumerCommitResponse |
ConsumerCommitResponse.Builder.build()
Build the response object.
|
Modifier and Type | Method and Description |
---|---|
ConsumerCommitResponse.Builder |
ConsumerCommitResponse.Builder.copy(ConsumerCommitResponse o)
Copy method to populate the builder with values from the given instance.
|
Copyright © 2016–2024. All rights reserved.