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

Package-level declarations

Types

@JsonSerializable

data class Header(val name: String, val value: String)

@JsonSerializable

data class KafkaPartition(val cluster_id: ClusterId, val metadata: Metadata, val topic_name: Topic, val partition_id: PartitionId, val leader: Relation, val replicas: Relation, val reassignment: Relation)

@JsonSerializable

@JsonSerializable

data class KafkaTopic(val cluster_id: ClusterId, val topic_name: Topic, val metadata: Metadata, val is_internal: Boolean, val replication_factor: Int, val partitions_count: Int, val partitions: Relation, val configs: Relation, val partition_reassignments: Relation, val authorized_operations: List<Any>)

@JsonSerializable

data class KafkaTopicList(val data: List<KafkaTopic>, val metadata: Metadata)

@JsonSerializable

data class ProducedRecord(val error_code: Status, val cluster_id: ClusterId, val topic_name: Topic, val partition_id: PartitionId, val offset: Offset, val timestamp: Instant, val key: ProducedRecordData?, val value: ProducedRecordData?)

@JsonSerializable

data class ProducedRecordData(val type: RecordFormat, val size: Int)