Package | Description |
---|---|
io.smallrye.reactive.messaging.kafka.impl.ce |
Modifier and Type | Class and Description |
---|---|
class |
DefaultIncomingKafkaCloudEventMetadata<K,T> |
Modifier and Type | Method and Description |
---|---|
static <T,K> IncomingKafkaCloudEventMetadata<K,T> |
KafkaCloudEventHelper.createFromBinaryCloudEvent(io.vertx.mutiny.kafka.client.consumer.KafkaConsumerRecord<?,T> record) |
static <T,K> IncomingKafkaCloudEventMetadata<K,T> |
KafkaCloudEventHelper.createFromStructuredCloudEvent(io.vertx.mutiny.kafka.client.consumer.KafkaConsumerRecord<K,T> record) |
Copyright © 2018–2021 SmallRye. All rights reserved.