Package io.confluent.monitoring.record

Interface Monitoring.MonitoringMessageOrBuilder

All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
All Known Implementing Classes:
Monitoring.MonitoringMessage, Monitoring.MonitoringMessage.Builder
Enclosing class:
Monitoring
public static interface Monitoring.MonitoringMessageOrBuilder extends com.google.protobuf.MessageOrBuilder

  • Method Details

    • getClientTypeValue

      int getClientTypeValue()
      .monitoring.ClientType clientType = 1;
      Returns:
      The enum numeric value on the wire for clientType.

    • getClientType

      Monitoring.ClientType getClientType()
      .monitoring.ClientType clientType = 1;
      Returns:
      The clientType.

    • getClientId

      String getClientId()
      string clientId = 2;
      Returns:
      The clientId.

    • getClientIdBytes

      com.google.protobuf.ByteString getClientIdBytes()
      string clientId = 2;
      Returns:
      The bytes for clientId.

    • getGroup

      String getGroup()
      string group = 3;
      Returns:
      The group.

    • getGroupBytes

      com.google.protobuf.ByteString getGroupBytes()
      string group = 3;
      Returns:
      The bytes for group.

    • getSession

      String getSession()
      string session = 4;
      Returns:
      The session.

    • getSessionBytes

      com.google.protobuf.ByteString getSessionBytes()
      string session = 4;
      Returns:
      The bytes for session.

    • getSequence

      long getSequence()
      int64 sequence = 5;
      Returns:
      The sequence.

    • getWindow

      long getWindow()
      int64 window = 6;
      Returns:
      The window.

    • getTimestamp

      long getTimestamp()
      int64 timestamp = 7;
      Returns:
      The timestamp.

    • getTopic

      String getTopic()
      string topic = 8;
      Returns:
      The topic.

    • getTopicBytes

      com.google.protobuf.ByteString getTopicBytes()
      string topic = 8;
      Returns:
      The bytes for topic.

    • getPartition

      int getPartition()
      int32 partition = 9;
      Returns:
      The partition.

    • getCount

      long getCount()
      int64 count = 10;
      Returns:
      The count.

    • getAggregateBytes

      long getAggregateBytes()
      int64 aggregateBytes = 11;
      Returns:
      The aggregateBytes.

    • getAggregateCrc

      int getAggregateCrc()
      int32 aggregateCrc = 12;
      Returns:
      The aggregateCrc.

    • getTotalLatency

      long getTotalLatency()
      int64 totalLatency = 13;
      Returns:
      The totalLatency.

    • getMinLatency

      long getMinLatency()
      int64 minLatency = 14;
      Returns:
      The minLatency.

    • getMaxLatency

      long getMaxLatency()
      int64 maxLatency = 15;
      Returns:
      The maxLatency.

    • getSamplePeriod

      long getSamplePeriod()
      int64 samplePeriod = 16;
      Returns:
      The samplePeriod.

    • getTypeValue

      int getTypeValue()
      .monitoring.MessageType type = 17;
      Returns:
      The enum numeric value on the wire for type.

    • getType

      Monitoring.MessageType getType()
      .monitoring.MessageType type = 17;
      Returns:
      The type.

    • getShutdown

      boolean getShutdown()
      bool shutdown = 18;
      Returns:
      The shutdown.

    • getMinWindow

      long getMinWindow()
      int64 minWindow = 19;
      Returns:
      The minWindow.

    • getMaxWindow

      long getMaxWindow()
      int64 maxWindow = 20;
      Returns:
      The maxWindow.

    • getMonitoringTopicPartition

      int getMonitoringTopicPartition()
      int32 monitoringTopicPartition = 21;
      Returns:
      The monitoringTopicPartition.

    • getClusterId

      String getClusterId()
       Kafka cluster ID (required)
      string clusterId = 22;
      Returns:
      The clusterId.

    • getClusterIdBytes

      com.google.protobuf.ByteString getClusterIdBytes()
       Kafka cluster ID (required)
      string clusterId = 22;
      Returns:
      The bytes for clusterId.

    • getClusterName

      String getClusterName()
       Kafka cluster name (optional, human-friendly)
      string clusterName = 23;
      Returns:
      The clusterName.

    • getClusterNameBytes

      com.google.protobuf.ByteString getClusterNameBytes()
       Kafka cluster name (optional, human-friendly)
      string clusterName = 23;
      Returns:
      The bytes for clusterName.

    • getArrivalTime

      long getArrivalTime()
       C3 time when the message arrived to C3
      int64 arrivalTime = 24;
      Returns:
      The arrivalTime.