Package | Description |
---|---|
org.thales.punch.kafka.api | |
org.thales.punch.kafka.impl |
Modifier and Type | Method and Description |
---|---|
static KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY |
KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY[] |
KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Constructor and Description |
---|
KafkaConsumerImpl(Properties props,
String[] topics,
int partitionNumber,
KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY startOffsetStrategy,
long startupOffset,
long fromTimestamp,
Long offsetWatchDogTimeout,
boolean continueWhenNoRecords,
org.thales.punch.platform.api.pojo.JavaStoreSecurity securityStores)
Ctor.
|
Copyright © 2014–2023. All rights reserved.