Package com.bakdata.kafka

Class SenderBuilder<K,V>

java.lang.Object
com.bakdata.kafka.SenderBuilder<K,V>
Type Parameters:
K - type of keys serialized by the reader
V - type of values serialized by the reader
public final class SenderBuilder<K,V> extends Object
Send data to a Kafka cluster

  • Method Details

    • with

      public SenderBuilder<K,V> with(String key, Object value)
      Add a producer configuration
      Parameters:
      key - configuration key
      value - configuration value
      Returns:
      SenderBuilder with added configuration

    • to

      public void to(String topic, Iterable<SenderBuilder.SimpleProducerRecord<K,V>> records)
      Send data to a topic
      Parameters:
      topic - topic to send to
      records - records to send

    • createProducer

      public org.apache.kafka.clients.producer.Producer<K,V> createProducer()
      Create a new Producer for a Kafka cluster
      Returns:
      Producer

    • withSerializers

      public <KN, VN> SenderBuilder<KN,VN> withSerializers(com.bakdata.kafka.Preconfigured<org.apache.kafka.common.serialization.Serializer<KN>> keySerializer, com.bakdata.kafka.Preconfigured<org.apache.kafka.common.serialization.Serializer<VN>> valueSerializer)
      Provide custom serializers for keys and values. Serializers are configured automatically.
      Type Parameters:
      KN - type of keys
      VN - type of values
      Parameters:
      keySerializer - serializer for keys
      valueSerializer - serializer for values
      Returns:
      SenderBuilder with custom serializers

    • withSerializers

      public <KN, VN> SenderBuilder<KN,VN> withSerializers(org.apache.kafka.common.serialization.Serializer<KN> keySerializer, org.apache.kafka.common.serialization.Serializer<VN> valueSerializer)
      Provide custom serializers for keys and values. Serializers are configured automatically.
      Type Parameters:
      KN - type of keys
      VN - type of values
      Parameters:
      keySerializer - serializer for keys
      valueSerializer - serializer for values
      Returns:
      SenderBuilder with custom serializers
      See Also:

    • withKeySerializer

      public <KN> SenderBuilder<KN,V> withKeySerializer(com.bakdata.kafka.Preconfigured<org.apache.kafka.common.serialization.Serializer<KN>> keySerializer)
      Provide a custom serializers for keys. Serializer is configured automatically.
      Type Parameters:
      KN - type of keys
      Parameters:
      keySerializer - serializer for keys
      Returns:
      SenderBuilder with custom key serializer

    • withKeySerializer

      public <KN> SenderBuilder<KN,V> withKeySerializer(org.apache.kafka.common.serialization.Serializer<KN> keySerializer)
      Provide a custom serializers for keys. Serializer is configured automatically.
      Type Parameters:
      KN - type of keys
      Parameters:
      keySerializer - serializer for keys
      Returns:
      SenderBuilder with custom key serializer
      See Also:

    • withValueSerializer

      public <VN> SenderBuilder<K,VN> withValueSerializer(com.bakdata.kafka.Preconfigured<org.apache.kafka.common.serialization.Serializer<VN>> valueSerializer)
      Provide a custom serializers for values. Serializer is configured automatically.
      Type Parameters:
      VN - type of values
      Parameters:
      valueSerializer - serializer for values
      Returns:
      SenderBuilder with custom value serializer

    • withValueSerializer

      public <VN> SenderBuilder<K,VN> withValueSerializer(org.apache.kafka.common.serialization.Serializer<VN> valueSerializer)
      Provide a custom serializers for values. Serializer is configured automatically.
      Type Parameters:
      VN - type of values
      Parameters:
      valueSerializer - serializer for values
      Returns:
      SenderBuilder with custom value serializer
      See Also: