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(org.apache.kafka.clients.consumer.ConsumerRecord<?,T> record) |
static <T,K> IncomingKafkaCloudEventMetadata<K,T> |
KafkaCloudEventHelper.createFromStructuredCloudEvent(org.apache.kafka.clients.consumer.ConsumerRecord<K,T> record) |
Copyright © 2018–2021 SmallRye. All rights reserved.