Package io.toro.martini

Class KafkaClientsMethods

java.lang.Object

io.toro.martini.KafkaClientsMethods

public final class KafkaClientsMethods
extends Object

Contains one-liners for Kafka-related operations.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	KafkaClientsMethods.SerializerClass

Constructor Summary

Constructors

Constructor	Description
KafkaClientsMethods(io.toro.martini.KafkaProducerFactory producerFactory)

Method Summary

Modifier and Type	Method	Description
static KafkaProducer	createProducer(String bootstrapServers, KafkaClientsMethods.SerializerClass keySerializer, KafkaClientsMethods.SerializerClass valueSerializer)	Deprecated, for removal: This API element is subject to removal in a future version. please use the overloaded method that has GloopExecutionContext parameter as it will do autoclose when gloop service finish
static KafkaProducer	createProducer(String bootstrapServers, KafkaClientsMethods.SerializerClass keySerializer, KafkaClientsMethods.SerializerClass valueSerializer, GloopExecutionContext context)	Creates a producer for publishing messages.
static KafkaProducer	createProducer(String bootstrapServers, KafkaClientsMethods.SerializerClass keySerializer, KafkaClientsMethods.SerializerClass valueSerializer, Properties producerConfigs)	Deprecated, for removal: This API element is subject to removal in a future version. please use the overloaded method that has GloopExecutionContext parameter as it will do autoclose when gloop service finish
static KafkaProducer	createProducer(String bootstrapServers, KafkaClientsMethods.SerializerClass keySerializer, KafkaClientsMethods.SerializerClass valueSerializer, Properties producerConfigs, GloopExecutionContext context)	Create a producer using the provided configuration, for publishing messages.
static KafkaProducer	createProducer(String bootstrapServers, Class<? extends Serializer> keySerializer, Class<? extends Serializer> valueSerializer)	Deprecated, for removal: This API element is subject to removal in a future version. please use the overloaded method that has GloopExecutionContext parameter as it will do autoclose when gloop service finish
static KafkaProducer	createProducer(String bootstrapServers, Class<? extends Serializer> keySerializer, Class<? extends Serializer> valueSerializer, GloopExecutionContext context)	Creates a producer for publishing messages.
static KafkaProducer	createProducer(String bootstrapServers, Properties producerConfigs)	Deprecated, for removal: This API element is subject to removal in a future version. please use the overloaded method that has GloopExecutionContext parameter as it will do autoclose when gloop service finish
static KafkaProducer	createProducer(String bootstrapServers, Properties producerConfigs, GloopExecutionContext context)	Creates a producer using the provided configuration, for publishing messages.
static void	send(KafkaProducer<Object,Object> producer, String topic, int partition, Object key, Object value)	Asynchronously send a record to a topic.
static void	send(KafkaProducer<Object,Object> producer, String topic, Object key, Object value)	Asynchronously send a record to a topic.

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaClientsMethods

public KafkaClientsMethods(io.toro.martini.KafkaProducerFactory producerFactory)

Method Detail

createProducer

@GloopObjectParameter("producer{\nproducer:object:KafkaProducer object\n}")
public static KafkaProducer createProducer(@GloopParameter(defaultValue="localhost:9092")
                                           String bootstrapServers,
                                           @GloopParameter(defaultValue="STRING")
                                           KafkaClientsMethods.SerializerClass keySerializer,
                                           @GloopParameter(defaultValue="STRING")
                                           KafkaClientsMethods.SerializerClass valueSerializer,
                                           Properties producerConfigs,
                                           GloopExecutionContext context)

Create a producer using the provided configuration, for publishing messages.

Parameters:

bootstrapServers - comma-separated values of host/port pairs to use for establishing initial connection to the Kafka cluster

keySerializer - serializer for key

valueSerializer - serializer for value

producerConfigs - configuration for the producer in key-value pairs

Returns:

KafkaProducer the producer

See Also:

valid producer configurations

createProducer

@Deprecated(since="2.0",
            forRemoval=true)
@GloopObjectParameter("producer{\nproducer:object:KafkaProducer object\n}")
public static KafkaProducer createProducer(@GloopParameter(defaultValue="localhost:9092")
                                           String bootstrapServers,
                                           @GloopParameter(defaultValue="STRING")
                                           KafkaClientsMethods.SerializerClass keySerializer,
                                           @GloopParameter(defaultValue="STRING")
                                           KafkaClientsMethods.SerializerClass valueSerializer,
                                           Properties producerConfigs)

Deprecated, for removal: This API element is subject to removal in a future version.

please use the overloaded method that has GloopExecutionContext parameter as it will do autoclose when gloop service finish

Create a producer using the provided configuration, for publishing messages.

Parameters:

bootstrapServers - comma-separated values of host/port pairs to use for establishing initial connection to the Kafka cluster

keySerializer - serializer for key

valueSerializer - serializer for value Kafka @param producerConfigs configuration for the producer in key-value pairs

Returns:

KafkaProducer the producer

See Also:

valid producer configurations

createProducer

public static KafkaProducer createProducer(@GloopParameter(defaultValue="localhost:9092")
                                           String bootstrapServers,
                                           @GloopParameter(defaultValue="STRING")
                                           KafkaClientsMethods.SerializerClass keySerializer,
                                           @GloopParameter(defaultValue="STRING")
                                           KafkaClientsMethods.SerializerClass valueSerializer,
                                           GloopExecutionContext context)

Creates a producer for publishing messages.

Parameters:

bootstrapServers - comma-separated values of host/port pairs to use for establishing initial connection to the Kafka cluster

keySerializer - serializer for key

valueSerializer - serializer for value

Returns:

KafkaProducer the producer

createProducer

@Deprecated(since="2.0",
            forRemoval=true)
public static KafkaProducer createProducer(@GloopParameter(defaultValue="localhost:9092")
                                           String bootstrapServers,
                                           @GloopParameter(defaultValue="STRING")
                                           KafkaClientsMethods.SerializerClass keySerializer,
                                           @GloopParameter(defaultValue="STRING")
                                           KafkaClientsMethods.SerializerClass valueSerializer)

Deprecated, for removal: This API element is subject to removal in a future version.

please use the overloaded method that has GloopExecutionContext parameter as it will do autoclose when gloop service finish

Creates a producer for publishing messages.

Parameters:

bootstrapServers - comma-separated values of host/port pairs to use for establishing initial connection to the Kafka cluster

keySerializer - serializer for key

valueSerializer - serializer for value

Returns:

KafkaProducer the producer

createProducer

public static KafkaProducer createProducer(@GloopParameter(defaultValue="localhost:9092")
                                           String bootstrapServers,
                                           Class<? extends Serializer> keySerializer,
                                           Class<? extends Serializer> valueSerializer,
                                           GloopExecutionContext context)

Creates a producer for publishing messages.

Parameters:

bootstrapServers - comma-separated values of host/port pairs to use for establishing initial connection to the Kafka cluster

keySerializer - serializer class for key that implements Serializer

valueSerializer - serializer class for value that implements Serializer

Returns:

KafkaProducer the producer

createProducer

@Deprecated(since="2.0",
            forRemoval=true)
public static KafkaProducer createProducer(@GloopParameter(defaultValue="localhost:9092")
                                           String bootstrapServers,
                                           Class<? extends Serializer> keySerializer,
                                           Class<? extends Serializer> valueSerializer)

Deprecated, for removal: This API element is subject to removal in a future version.

please use the overloaded method that has GloopExecutionContext parameter as it will do autoclose when gloop service finish

Creates a producer for publishing messages.

Parameters:

bootstrapServers - comma-separated values of host/port pairs to use for establishing initial connection to the Kafka cluster

keySerializer - serializer class for key that implements Serializer

valueSerializer - serializer class for value that implements Serializer

Returns:

KafkaProducer the producer

createProducer

public static KafkaProducer createProducer(@GloopParameter(defaultValue="localhost:9092")
                                           String bootstrapServers,
                                           Properties producerConfigs,
                                           GloopExecutionContext context)

Creates a producer using the provided configuration, for publishing messages.

Parameters:

bootstrapServers - comma-separated values of host/port pairs to use for establishing initial connection to the Kafka cluster

producerConfigs - configuration for the produces in key-value pairs

Returns:

KafkaProducer the producer

See Also:

valid producer configurations

createProducer

@Deprecated(since="2.0",
            forRemoval=true)
public static KafkaProducer createProducer(@GloopParameter(defaultValue="localhost:9092")
                                           String bootstrapServers,
                                           Properties producerConfigs)

Deprecated, for removal: This API element is subject to removal in a future version.

please use the overloaded method that has GloopExecutionContext parameter as it will do autoclose when gloop service finish

Creates a producer using the provided configuration, for publishing messages.

Parameters:

bootstrapServers - comma-separated values of host/port pairs to use for establishing initial connection to the Kafka cluster

producerConfigs - configuration for the produces in key-value pairs

Returns:

KafkaProducer the producer

See Also:

valid producer configurations

send

public static void send(KafkaProducer<Object,Object> producer,
                        String topic,
                        Object key,
                        Object value)

Asynchronously send a record to a topic.

Parameters:

producer - the producer object

topic - the topic the message will be appended to

key - the key that will be included in the message

value - the record contents

send

public static void send(KafkaProducer<Object,Object> producer,
                        String topic,
                        int partition,
                        Object key,
                        Object value)

Asynchronously send a record to a topic.

Parameters:

producer - the producer object

topic - the topic the message will be appended to

partition - the partition to which the record should be sent

key - the key that will be included in the message

value - the record contents