Package | Description |
---|---|
com.oracle.bmc.streaming | |
com.oracle.bmc.streaming.requests |
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.
|
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 |
---|---|
ConsumerCommitRequest |
ConsumerCommitRequest.Builder.build()
Build the instance of ConsumerCommitRequest as configured by this builder
|
ConsumerCommitRequest |
ConsumerCommitRequest.Builder.buildWithoutInvocationCallback()
Build the instance of ConsumerCommitRequest as configured by this builder
|
Modifier and Type | Method and Description |
---|---|
ConsumerCommitRequest.Builder |
ConsumerCommitRequest.Builder.copy(ConsumerCommitRequest o)
Copy method to populate the builder with values from the given instance.
|
Copyright © 2016–2024. All rights reserved.