Package com.zendesk.maxwell.producer

Class MaxwellKinesisProducer

java.lang.Object

com.zendesk.maxwell.producer.AbstractProducer

com.zendesk.maxwell.producer.AbstractAsyncProducer

com.zendesk.maxwell.producer.MaxwellKinesisProducer

public class MaxwellKinesisProducer
extends AbstractAsyncProducer

Nested Class Summary

Nested classes/interfaces inherited from class com.zendesk.maxwell.producer.AbstractAsyncProducer

AbstractAsyncProducer.CallbackCompleter

Field Summary

Fields inherited from class com.zendesk.maxwell.producer.AbstractProducer

context, failedMessageCount, failedMessageMeter, messageLatencySloViolationCount, messageLatencyTimer, messagePublishTimer, outputConfig, succeededMessageCount, succeededMessageMeter

Constructor Summary

Constructors

Constructor	Description
MaxwellKinesisProducer(MaxwellContext context, String kinesisStream)

Method Summary

Modifier and Type	Method	Description
void	close()
void	sendAsync(RowMap r, AbstractAsyncProducer.CallbackCompleter cc)

Methods inherited from class com.zendesk.maxwell.producer.AbstractAsyncProducer

push

Methods inherited from class com.zendesk.maxwell.producer.AbstractProducer

getDiagnostic, getFailedMessageMeter, getStoppableTask

Methods inherited from class java.lang.Object

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

Constructor Detail

MaxwellKinesisProducer

public MaxwellKinesisProducer(MaxwellContext context,
                              String kinesisStream)

Method Detail

sendAsync

public void sendAsync(RowMap r,
                      AbstractAsyncProducer.CallbackCompleter cc)
               throws Exception

Specified by:

sendAsync in class AbstractAsyncProducer

Throws:

Exception

close

public void close()