Package org.springframework.cloud.stream.binder.kafka.streams.endpoint

Class KafkaStreamsTopologyEndpoint

java.lang.Object

org.springframework.cloud.stream.binder.kafka.streams.endpoint.KafkaStreamsTopologyEndpoint

@Endpoint(id="kafkastreamstopology")
public class KafkaStreamsTopologyEndpoint
extends Object

Actuator endpoint for topology description.

Since:

3.0.4

Author:

Soby Chacko

Field Summary

Fields

Modifier and Type	Field	Description
static final String	NO_TOPOLOGY_FOUND_MSG	Topology not found message.

Constructor Summary

Constructors

Constructor	Description
KafkaStreamsTopologyEndpoint(KafkaStreamsRegistry kafkaStreamsRegistry)

Method Summary

Modifier and Type	Method	Description
List<String>	kafkaStreamsTopologies()
String	kafkaStreamsTopology(String applicationId)

Methods inherited from class java.lang.Object

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

Field Details

NO_TOPOLOGY_FOUND_MSG

public static final String NO_TOPOLOGY_FOUND_MSG

Topology not found message.

See Also:

• Constant Field Values

Constructor Details

KafkaStreamsTopologyEndpoint

public KafkaStreamsTopologyEndpoint(KafkaStreamsRegistry kafkaStreamsRegistry)

Method Details

kafkaStreamsTopologies

@ReadOperation
public List<String> kafkaStreamsTopologies()

kafkaStreamsTopology

@ReadOperation
public String kafkaStreamsTopology(@Selector
 String applicationId)