Package io.streamthoughts.azkarra.runtime.interceptors.monitoring

Class StreamsExtensionBuilder

java.lang.Object

io.streamthoughts.azkarra.runtime.interceptors.monitoring.StreamsExtensionBuilder

public final class StreamsExtensionBuilder
extends Object

Method Summary

Modifier and Type	Method	Description
CloudEventsExtension	build()
static StreamsExtensionBuilder	newBuilder()
StreamsExtensionBuilder	with(String key, Object value)
StreamsExtensionBuilder	withApplicationId(String applicationId)	Sets the Kafka Streams application.id.
StreamsExtensionBuilder	withApplicationServer(String applicationServer)	Sets the Kafka Streams application.server.

Methods inherited from class java.lang.Object

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

Method Detail

newBuilder

public static StreamsExtensionBuilder newBuilder()

withApplicationServer

public StreamsExtensionBuilder withApplicationServer(String applicationServer)

Sets the Kafka Streams application.server.

Parameters:

applicationServer - theStreamsConfig.APPLICATION_SERVER_CONFIG property.

Returns:

this

withApplicationId

public StreamsExtensionBuilder withApplicationId(String applicationId)

Sets the Kafka Streams application.id.

Parameters:

applicationId - theStreamsConfig.APPLICATION_ID_CONFIG property.

Returns:

this

with

public StreamsExtensionBuilder with(String key,
                                    Object value)

build

public CloudEventsExtension build()