Package app.l2nx.gs.adapter.core.events

Interface EventsPublisher.Sender

Enclosing class:
EventsPublisher
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 EventsPublisher.Sender
Bridge to the actual Kafka send. Production wires this to (record, callback) -> NxKafka.instance().sendBytesKeyRecord(record, callback); tests inject a recording fake.

  • 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)