Package org.gridgain.kafka.sink

Class GridGainSinkTask

java.lang.Object
org.apache.kafka.connect.sink.SinkTask
org.gridgain.kafka.sink.GridGainSinkTask
All Implemented Interfaces:
org.apache.kafka.connect.connector.Task
public final class GridGainSinkTask extends org.apache.kafka.connect.sink.SinkTask
Task that takes records loaded from Kafka and stores them in GridGain tables.

  • Field Summary

    Fields inherited from class org.apache.kafka.connect.sink.SinkTask

    context, TOPICS_CONFIG, TOPICS_REGEX_CONFIG

  • Constructor Summary

    Constructors
    Constructor
    Description
    GridGainSinkTask()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    flush(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> currentOffsets)
     
    void
    put(Collection<org.apache.kafka.connect.sink.SinkRecord> collection)
     
    void
    start(Map<String,String> map)
     
    void
    stop()
     
    String
    version()
     

    Methods inherited from class org.apache.kafka.connect.sink.SinkTask

    close, initialize, onPartitionsAssigned, onPartitionsRevoked, open, preCommit

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • GridGainSinkTask

      public GridGainSinkTask()

  • Method Details

    • version

      public String version()

    • start

      public void start(Map<String,String> map)
      Specified by:
      start in interface org.apache.kafka.connect.connector.Task
      Specified by:
      start in class org.apache.kafka.connect.sink.SinkTask

    • put

      public void put(Collection<org.apache.kafka.connect.sink.SinkRecord> collection)
      Specified by:
      put in class org.apache.kafka.connect.sink.SinkTask

    • stop

      public void stop()
      Specified by:
      stop in interface org.apache.kafka.connect.connector.Task
      Specified by:
      stop in class org.apache.kafka.connect.sink.SinkTask

    • flush

      public void flush(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> currentOffsets)
      Overrides:
      flush in class org.apache.kafka.connect.sink.SinkTask