org.cripac.isee.vpe.util.kafka

Class ByteArrayProducer

java.lang.Object

org.apache.kafka.clients.producer.KafkaProducer<String,byte[]>

org.cripac.isee.vpe.util.kafka.ByteArrayProducer

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.clients.producer.Producer<String,byte[]>

public class ByteArrayProducer
extends org.apache.kafka.clients.producer.KafkaProducer<String,byte[]>

Constructor Summary

Constructors

Constructor and Description
ByteArrayProducer(Map<String,Object> configs) A producer is instantiated by providing a set of key-value pairs as configuration.
ByteArrayProducer(Map<String,Object> configs, org.apache.kafka.common.serialization.Serializer<String> keySerializer, org.apache.kafka.common.serialization.Serializer<byte[]> valueSerializer) A producer is instantiated by providing a set of key-value pairs as configuration, a key and a value Serializer.
ByteArrayProducer(Properties properties) A producer is instantiated by providing a set of key-value pairs as configuration.
ByteArrayProducer(Properties properties, org.apache.kafka.common.serialization.Serializer<String> keySerializer, org.apache.kafka.common.serialization.Serializer<byte[]> valueSerializer) A producer is instantiated by providing a set of key-value pairs as configuration, a key and a value Serializer.

Method Summary

Methods inherited from class org.apache.kafka.clients.producer.KafkaProducer

close, close, flush, metrics, partitionsFor, send, send

Methods inherited from class java.lang.Object

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

Constructor Detail

ByteArrayProducer

public ByteArrayProducer(Map<String,Object> configs)

A producer is instantiated by providing a set of key-value pairs as configuration. Valid configuration strings are documented here. Values can be either strings or Objects of the appropriate type (for example a numeric configuration would accept either the string "42" or the integer 42).

Parameters:

configs - The producer configs

ByteArrayProducer

public ByteArrayProducer(Map<String,Object> configs,
                         org.apache.kafka.common.serialization.Serializer<String> keySerializer,
                         org.apache.kafka.common.serialization.Serializer<byte[]> valueSerializer)

A producer is instantiated by providing a set of key-value pairs as configuration, a key and a value Serializer. Valid configuration strings are documented here. Values can be either strings or Objects of the appropriate type (for example a numeric configuration would accept either the string "42" or the integer 42).

Parameters:

configs - The producer configs

keySerializer - The serializer for key that implements Serializer. The configure() method won't be called in the producer when the serializer is passed in directly.

valueSerializer - The serializer for value that implements Serializer. The configure() method won't

ByteArrayProducer

public ByteArrayProducer(Properties properties)

A producer is instantiated by providing a set of key-value pairs as configuration. Valid configuration strings are documented here.

Parameters:

properties - The producer configs

ByteArrayProducer

public ByteArrayProducer(Properties properties,
                         org.apache.kafka.common.serialization.Serializer<String> keySerializer,
                         org.apache.kafka.common.serialization.Serializer<byte[]> valueSerializer)

A producer is instantiated by providing a set of key-value pairs as configuration, a key and a value Serializer. Valid configuration strings are documented here.

Parameters:

properties - The producer configs

keySerializer - The serializer for key that implements Serializer. The configure() method won't be called in the producer when the serializer is passed in directly.

valueSerializer - The serializer for value that implements Serializer. The configure() method won't