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

Package-level declarations

Types

data class CommitOffsets(val group: ConsumerGroup, val instance: ConsumerInstance, val offsets: List<CommitOffset>) : NullableKafkaRestAction<Unit> , KafkaRestV2Action<Unit?>

data class ConsumeRecords(val group: ConsumerGroup, val instance: ConsumerInstance, val format: RecordFormat, val timeout: Duration? = null) : NullableKafkaRestAction<Array<TopicRecord>> , KafkaRestV2Action<Array<TopicRecord>?>

data class CreateConsumer(val group: ConsumerGroup, val consumer: Consumer) : NonNullKafkaRestAction<NewConsumer> , KafkaRestV2Action<NewConsumer>

data class DeleteConsumer(val group: ConsumerGroup, val instance: ConsumerInstance) : NullableKafkaRestAction<Unit> , KafkaRestV2Action<Unit?>

data class GetOffsets(val group: ConsumerGroup, val instance: ConsumerInstance, val partitions: List<PartitionOffsetRequest>) : NullableKafkaRestAction<CommitOffsetsSet> , KafkaRestV2Action<CommitOffsetsSet?>

data class GetPartitions(val topic: Topic) : NullableKafkaRestAction<Array<Partition>> , KafkaRestV2Action<Array<Partition>?>

@JsonSerializable

data class NewConsumer(val instance_id: ConsumerInstance, val base_uri: Uri)

@JsonSerializable

data class Partition(val partition: PartitionId, val leader: BrokerId, val replicas: List<Replica>)

ProducedMessages

@JsonSerializable

data class ProducedMessages(val key_schema_id: SchemaId?, val value_schema_id: SchemaId?, val offsets: List<PartitionOffset>)

ProduceMessages

data class ProduceMessages(val topic: Topic, val records: Records) : NullableKafkaRestAction<ProducedMessages> , KafkaRestV2Action<ProducedMessages?>

@JsonSerializable

data class Replica(val broker: BrokerId, val leader: Boolean, val in_sync: Boolean)

data class SeekOffsets(val group: ConsumerGroup, val instance: ConsumerInstance, val offsets: List<SeekOffset>) : NullableKafkaRestAction<Unit> , KafkaRestV2Action<Unit?>

SubscribeToTopics

data class SubscribeToTopics(val group: ConsumerGroup, val instance: ConsumerInstance, val topics: List<Topic>) : NullableKafkaRestAction<Unit> , KafkaRestV2Action<Unit?>