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

Package-level declarations

Types

Link copied to clipboard
@JsonSerializable
data class CommitOffset(val topic: Topic, val partition: PartitionId, val offset: Offset, val metadata: String = "")
Link copied to clipboard
@JsonSerializable
data class CommitOffsetsSet(val offsets: List<CommitOffset>)
Link copied to clipboard
@JsonSerializable
data class Consumer(val name: ConsumerInstance, val format: RecordFormat, @Json(name = "auto.offset.reset") val reset: AutoOffsetReset = latest, @Json(name = "auto.commit.enable") val enableAutocommit: AutoCommitEnable = `true`, @Json(name = "fetch.min.bytes") val minBytes: String? = null, @Json(name = "consumer.request.timeout.ms") val timeout: ConsumerRequestTimeout? = null)
Link copied to clipboard
@JsonSerializable
data class GetOffsetsRequest(val partitions: List<PartitionOffsetRequest>)
Link copied to clipboard
@JsonSerializable
data class PartitionOffset(val partition: PartitionId, val offset: Offset)
Link copied to clipboard
@JsonSerializable
data class PartitionOffsetRequest(val topic: Topic, val partition: PartitionId)
Link copied to clipboard
@JsonSerializable
data class Record<K : Any, out V : Any>(val key: K?, val value: V, val partition: PartitionId? = null)
Link copied to clipboard
Link copied to clipboard
data class Records
Link copied to clipboard
@JsonSerializable
data class SeekOffset(val topic: Topic, val partition: PartitionId, val offset: Offset)
Link copied to clipboard
@JsonSerializable
data class SeekOffsetsSet(val offsets: List<SeekOffset>)
Link copied to clipboard
@JsonSerializable
data class Subscription(val topics: List<Topic>)
Link copied to clipboard
@JsonSerializable
data class TopicRecord(val topic: Topic, val key: Any?, val value: Any?, val partition: PartitionId, val offset: Offset)