Package app.l2nx.gs.adapter.core.commands

Interface CommandsConsumer.ReplySender

Enclosing class:
CommandsConsumer
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public static interface CommandsConsumer.ReplySender
Bridge to the actual Kafka send. Production wires this to (record, callback) -> NxKafka.instance().sendBytesKeyRecord(record, callback).

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    send(org.apache.kafka.clients.producer.ProducerRecord<byte[],Object> record, org.apache.kafka.clients.producer.Callback callback)
     

  • Method Details

    • send

      void send(org.apache.kafka.clients.producer.ProducerRecord<byte[],Object> record, org.apache.kafka.clients.producer.Callback callback)