Class KafkaStreamsInstance

  • All Implemented Interfaces:
    HasId

    public class KafkaStreamsInstance
    extends Object
    implements HasId
    A KafkaStreamsInstance regroups information about a Kafka Streams instance running either locally or remotely.
    • Constructor Detail

      • KafkaStreamsInstance

        public KafkaStreamsInstance​(String id,
                                    Endpoint endpoint,
                                    boolean isLocal,
                                    KafkaStreamsMetadata metadata)
        Creates a new KafkaStreamsInstance instance.
        Parameters:
        id - the identifier for this instance, i.e. the container id.
        endpoint - the endpoint for this instance.
        isLocal - a flag to indicate if this instance is running locally.
        metadata - the metadata for this instance.