Package com.here.platform.data.client.service.stream.kafka

Interface Producer

All Known Implementing Classes:
ProducerImpl
public interface Producer
Wraps KafkaProducer through async non blocking methods

  • Method Summary

    Modifier and Type
    Method
    Description
    scala.concurrent.Future<org.apache.pekko.Done>
    close()
     
    scala.concurrent.Future<org.apache.pekko.Done>
    send(PublishPartition partition, boolean isCompressed)
     

  • Method Details

    • send

      scala.concurrent.Future<org.apache.pekko.Done> send(PublishPartition partition, boolean isCompressed)

    • close

      scala.concurrent.Future<org.apache.pekko.Done> close()