K
- Stream key and Stream field type.public static class StreamMessageListenerContainer.StreamReadRequest<K> extends Object
Modifier and Type | Method and Description |
---|---|
static <K> StreamMessageListenerContainer.StreamReadRequestBuilder<K> |
builder(StreamOffset<K> offset) |
Predicate<Throwable> |
getCancelSubscriptionOnError() |
ErrorHandler |
getErrorHandler() |
StreamOffset<K> |
getStreamOffset() |
public static <K> StreamMessageListenerContainer.StreamReadRequestBuilder<K> builder(StreamOffset<K> offset)
StreamMessageListenerContainer.StreamReadRequest
.public StreamOffset<K> getStreamOffset()
@Nullable public ErrorHandler getErrorHandler()
Copyright © 2011–2019 Pivotal Software, Inc.. All rights reserved.