org.thales.punch.kafka.platform

Class KafkaAdminProducerUtil

java.lang.Object

org.thales.punch.kafka.platform.KafkaAdminProducerUtil

public class KafkaAdminProducerUtil
extends Object

This class groups the various values that are part of the Punch protocol implemented on top of Kafka.

This protocol is used by the core punch administration to keep track of channels and applications status, as well as by the shiva application scheduler.

Author:

dimi

Method Summary

Modifier and Type	Method and Description
static org.apache.kafka.clients.producer.KafkaProducer<String,byte[]>	getAdminProducer(String bootstrapServers, org.thales.punch.platform.api.pojo.JavaStoreSecurity securityStores) Return a producer for admin purpose.

Methods inherited from class java.lang.Object

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

Method Detail

getAdminProducer

public static org.apache.kafka.clients.producer.KafkaProducer<String,byte[]> getAdminProducer(String bootstrapServers,
                                                                                              org.thales.punch.platform.api.pojo.JavaStoreSecurity securityStores)

Return a producer for admin purpose.

Note that this producer is designed to succeed in writing to Kafka even though not all Kafka servers are up and running.

The idea is to make that consumer able to keep working in non-nominal situations.

Parameters:

bootstrapServers - kafka addresses

securityStores - the Object containing the truststore and keystore information. If not null, activate ssl.

Returns:

your producer.