static <K> OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> |
OutgoingKafkaRecordMetadata.builder() |
|
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> |
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder.withHeaders(List<org.apache.kafka.common.header.internals.RecordHeader> headers) |
Specify the headers for the Kafka record
|
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> |
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder.withHeaders(org.apache.kafka.common.header.Headers headers) |
Specify headers for Kafka the timestamp for the Kafka record
|
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> |
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder.withKey(K recordKey) |
Set the Kafka record key
|
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> |
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder.withPartition(int partition) |
In most cases Kafka's partitioner should be used to chose the Kafka partition.
|
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> |
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder.withTimestamp(Instant timestamp) |
Specify the timestamp for the Kafka record
|
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> |
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder.withTopic(String topic) |
By default the hardcoded topic in the configuration is used.
|