| 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.