org.apache.twill.kafka.client

Interface KafkaPublisher

public interface KafkaPublisher

This interface is for publishing data to Kafka.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	KafkaPublisher.Ack Represents the desired level of publish acknowledgment.
static interface	KafkaPublisher.Preparer A Preparer for preparing to publish messages to a given topic.

Method Summary

Modifier and Type	Method and Description
KafkaPublisher.Preparer	prepare(String topic) Prepares to publish to a given topic.

Method Detail

prepare

KafkaPublisher.Preparer prepare(String topic)

Prepares to publish to a given topic.

Parameters:

topic - Name of the topic.

Returns:

A KafkaPublisher.Preparer to prepare for publishing.