Package | Description |
---|---|
org.thales.punch.kafka.api | |
org.thales.punch.kafka.application | |
org.thales.punch.kafka.impl | |
org.thales.punch.kafka.platform |
Class and Description |
---|
IKafkaContinuousConsumer
The IKafkaContinuousConsumer is your main interface to continuously consume kafka topics.
|
IPartition
This interface lets you receive, acknowledge your records, in a way to let you
achieve at-least/exactly once semantics.
|
IRecordHandler
This is your interface to receive Kafka records.
|
KafkaContinuousConsumerBuilder
The
IKafkaContinuousConsumer builder. |
KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY
One of "earliest", "last_committed", "latest", "from_offset" or "from_timestamp".
|
KafkaSettingsMapConsumerBuilder
The
IKafkaContinuousConsumer builder. |
Class and Description |
---|
IPartition
This interface lets you receive, acknowledge your records, in a way to let you
achieve at-least/exactly once semantics.
|
IRecordHandler
This is your interface to receive Kafka records.
|
Class and Description |
---|
IKafkaContinuousConsumer
The IKafkaContinuousConsumer is your main interface to continuously consume kafka topics.
|
IPartition
This interface lets you receive, acknowledge your records, in a way to let you
achieve at-least/exactly once semantics.
|
IRecordHandler
This is your interface to receive Kafka records.
|
KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY
One of "earliest", "last_committed", "latest", "from_offset" or "from_timestamp".
|
Class and Description |
---|
IKafkaSettingsMapConsumer
The IKafkaSettingsMapConsumer is your main interface to read the latest settings map record
from a punch admin topic or assignement topic.
|
KafkaContinuousConsumerBuilder
The
IKafkaContinuousConsumer builder. |
Copyright © 2014–2023. All rights reserved.