Interface KafkaMessage<K,​T>

    • Method Detail

      • of

        static <K,​T> OutgoingKafkaRecord<K,​T> of​(K key,
                                                             T value)
        Deprecated.
        Creates a new outgoing kafka message.
        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 message
      • of

        static <K,​T> OutgoingKafkaRecord<K,​T> of​(String topic,
                                                             K key,
                                                             T value)
        Deprecated.
        Creates a new outgoing kafka message.
        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 message
      • of

        static <K,​T> OutgoingKafkaRecord<K,​T> of​(String topic,
                                                             K key,
                                                             T value,
                                                             Instant timestamp,
                                                             int partition)
        Deprecated.
        Creates a new outgoing kafka message.
        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 message