Interface KafkaRecord<K,​T>

    • Method Detail

      • of

        static <K,​T> OutgoingKafkaRecord<K,​T> of​(K key,
                                                             T value)
        Creates a new outgoing Kafka record.
        Type Parameters:
        K - the type of the key
        T - the type of the value
        Parameters:
        key - the key, can be null
        value - the value / payload, must not be null
        Returns:
        the new outgoing Kafka record
      • of

        static <K,​T> OutgoingKafkaRecord<K,​T> of​(String topic,
                                                             K key,
                                                             T value)
        Creates a new outgoing Kafka record.
        Type Parameters:
        K - the type of the key
        T - the type of the value
        Parameters:
        topic - the topic, must not be null
        key - the key, can be null
        value - the value / payload, must not be null
        Returns:
        the new outgoing Kafka record
      • of

        static <K,​T> OutgoingKafkaRecord<K,​T> of​(String topic,
                                                             K key,
                                                             T value,
                                                             Instant timestamp,
                                                             int partition)
        Creates a new outgoing Kafka record.
        Type Parameters:
        K - the type of the key
        T - the type of the value
        Parameters:
        topic - the topic, must not be null
        key - the key, can be null
        value - the value / payload, must not be null
        timestamp - the timestamp, can be null to indicate no timestamp
        partition - the partition, can be -1 to indicate no partition
        Returns:
        the new outgoing Kafka record
      • getKey

        K getKey()
      • getPartition

        int getPartition()
      • getTimestamp

        Instant getTimestamp()
      • getHeaders

        org.apache.kafka.common.header.Headers getHeaders()