Uses of Class
io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecord

Packages that use OutgoingKafkaRecord

Package	Description
io.smallrye.reactive.messaging.kafka

Uses of OutgoingKafkaRecord in io.smallrye.reactive.messaging.kafka

Methods in io.smallrye.reactive.messaging.kafka that return OutgoingKafkaRecord

Modifier and Type	Method and Description
static <K,T> OutgoingKafkaRecord<K,T>	OutgoingKafkaRecord.from(Message<T> message)
static <K,T> OutgoingKafkaRecord<K,T>	KafkaRecord.from(Message<T> message)
static <K,T> OutgoingKafkaRecord<K,T>	KafkaRecord.of(K key, T value) Creates a new outgoing Kafka record.
static <K,T> OutgoingKafkaRecord<K,T>	KafkaMessage.of(K key, T value) Deprecated. Creates a new outgoing kafka message.
static <K,T> OutgoingKafkaRecord<K,T>	KafkaRecord.of(String topic, K key, T value) Creates a new outgoing Kafka record.
static <K,T> OutgoingKafkaRecord<K,T>	KafkaMessage.of(String topic, K key, T value) Deprecated. Creates a new outgoing kafka message.
static <K,T> OutgoingKafkaRecord<K,T>	KafkaRecord.of(String topic, K key, T value, Instant timestamp, int partition) Creates a new outgoing Kafka record.
static <K,T> OutgoingKafkaRecord<K,T>	KafkaMessage.of(String topic, K key, T value, Instant timestamp, int partition) Deprecated. Creates a new outgoing kafka message.
OutgoingKafkaRecord<K,T>	OutgoingKafkaRecord.with(String topic, K key, T value)
OutgoingKafkaRecord<K,T>	OutgoingKafkaRecord.with(String topic, K key, T value, Instant timestamp, int partition)
OutgoingKafkaRecord<K,T>	OutgoingKafkaRecord.with(String topic, T value)
OutgoingKafkaRecord<K,T>	OutgoingKafkaRecord.withAck(Supplier<CompletionStage<Void>> supplier)
OutgoingKafkaRecord<K,T>	OutgoingKafkaRecord.withHeader(String key, byte[] content) Creates a new outgoing Kafka Message with a header added to the header list.
OutgoingKafkaRecord<K,T>	OutgoingKafkaRecord.withHeader(String key, String content) Creates a new outgoing Kafka Message with a header added to the header list.
OutgoingKafkaRecord<K,T>	OutgoingKafkaRecord.withHeader(String key, String content, Charset enc) Creates a new outgoing Kafka Message with a header added to the header list.
OutgoingKafkaRecord<K,T>	OutgoingKafkaRecord.withMetadata(Iterable<Object> metadata)
OutgoingKafkaRecord<K,T>	OutgoingKafkaRecord.withMetadata(Metadata metadata)
OutgoingKafkaRecord<K,T>	OutgoingKafkaRecord.withNack(Function<Throwable,CompletionStage<Void>> nack)
<P> OutgoingKafkaRecord<K,P>	OutgoingKafkaRecord.withPayload(P payload)