http4k-connect-kafka-rest/org.http4k.connect.kafka.rest.v2.action.consumer

Package-level declarations

Types

data class CommitOffsets(val offsets: List<CommitOffset>) : NonNullKafkaRestAction<Unit> , KafkaRestConsumerAction<Unit>

data class ConsumeRecords(val format: RecordFormat, val timeout: Duration? = null) : NonNullKafkaRestAction<Array<TopicRecord>> , KafkaRestConsumerAction<Array<TopicRecord>>

object Delete : NullableKafkaRestAction<Unit> , KafkaRestConsumerAction<Unit?>

data class GetOffsets(val partitions: List<PartitionOffsetRequest>) : NonNullKafkaRestAction<CommitOffsetsSet> , KafkaRestConsumerAction<CommitOffsetsSet>

data class SeekOffsets(val offsets: List<SeekOffset>) : NonNullKafkaRestAction<Unit> , KafkaRestConsumerAction<Unit>

SubscribeToTopics

data class SubscribeToTopics(val topics: List<Topic>) : NonNullKafkaRestAction<Unit> , KafkaRestConsumerAction<Unit>