Package com.facebook.openwifi.cloudsdk.kafka

Class UCentralKafkaProducer

java.lang.Object

com.facebook.openwifi.cloudsdk.kafka.UCentralKafkaProducer

public class UCentralKafkaProducer
extends Object

Kafka producer for uCentral.

Constructor Summary

Constructors

Constructor	Description
UCentralKafkaProducer(String bootstrapServer, String serviceEventsTopic, String serviceType, String serviceVersion, long serviceId, String serviceKey, String privateEndpoint, String publicEndpoint)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	close()	Close the producer.
void	publishSystemEvent(String event)	Publish a service event.

Methods inherited from class java.lang.Object

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

Constructor Detail

UCentralKafkaProducer

public UCentralKafkaProducer(String bootstrapServer,
                             String serviceEventsTopic,
                             String serviceType,
                             String serviceVersion,
                             long serviceId,
                             String serviceKey,
                             String privateEndpoint,
                             String publicEndpoint)

Constructor.

Parameters:

bootstrapServer - the Kafka bootstrap server

serviceEventsTopic - the uCentral service_events topic (required)

serviceType - the service name

serviceVersion - the service version

serviceId - the service ID

serviceKey - the service key

privateEndpoint - the private service endpoint

publicEndpoint - the public service endpoint

Method Detail

publishSystemEvent

public void publishSystemEvent(String event)

Publish a service event.

close

public void close()

Close the producer.