com.logicalclocks.hsfs.beam.engine

Class BeamKafkaProducer

java.lang.Object

org.apache.kafka.clients.producer.KafkaProducer<String,org.apache.avro.generic.GenericRecord>

com.logicalclocks.hsfs.beam.engine.BeamKafkaProducer

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.clients.producer.Producer<String,org.apache.avro.generic.GenericRecord>

public class BeamKafkaProducer
extends org.apache.kafka.clients.producer.KafkaProducer<String,org.apache.avro.generic.GenericRecord>

Field Summary

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

NETWORK_THREAD_PREFIX, PRODUCER_METRIC_GROUP_NAME

Constructor Summary

Constructors

Constructor and Description
BeamKafkaProducer(Map configs)

Method Summary

Modifier and Type	Method and Description
Future<org.apache.kafka.clients.producer.RecordMetadata>	send(org.apache.kafka.clients.producer.ProducerRecord record)
Future<org.apache.kafka.clients.producer.RecordMetadata>	send(org.apache.kafka.clients.producer.ProducerRecord record, org.apache.kafka.clients.producer.Callback callback)

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

abortTransaction, beginTransaction, close, close, commitTransaction, flush, initTransactions, metrics, partitionsFor, sendOffsetsToTransaction, sendOffsetsToTransaction

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamKafkaProducer

public BeamKafkaProducer(Map configs)

Method Detail

send

public Future<org.apache.kafka.clients.producer.RecordMetadata> send(org.apache.kafka.clients.producer.ProducerRecord record)

Specified by:

send in interface org.apache.kafka.clients.producer.Producer<String,org.apache.avro.generic.GenericRecord>

Overrides:

send in class org.apache.kafka.clients.producer.KafkaProducer<String,org.apache.avro.generic.GenericRecord>

send

public Future<org.apache.kafka.clients.producer.RecordMetadata> send(org.apache.kafka.clients.producer.ProducerRecord record,
                                                                     org.apache.kafka.clients.producer.Callback callback)

Specified by:

send in interface org.apache.kafka.clients.producer.Producer<String,org.apache.avro.generic.GenericRecord>

Overrides:

send in class org.apache.kafka.clients.producer.KafkaProducer<String,org.apache.avro.generic.GenericRecord>