THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Traffic analysis. It allows detailed analysis of traffic on particular topics, for particular principles, or for specific request types. Useful information could be derived from the audit information. For example, user can easily figure out what topics have not been accessed for some certain period of time. With this information, users can initiate some topic deletion process and etc.
Correctness analysis and reporting. There could be various definitions on “correctness”. For example, “correctness” could be defined as whether the number of records produced to a Kafka cluster equals the number of records that is mirrored to another cluster.
SLO monitoring. The response time to a request could be broken down by topic, principle or any other arbitrary criteria.
Cost attribution. For example, the number of bytes produced or consumed could be broken down by topic, principle or any other arbitrary criteria.
...
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
public interface ObservableStruct {
public Byte get(Field.Int8 field);
public Integer get(Field.Int32 field);
public Long get(Field.Int64 field);
public Short get(Field.Int16 field);
public String get(Field.Str field);
public String get(Field.NullableStr field);
public Long getOrElse(Field.Int64 field, long alternative);
public Short getOrElse(Field.Int16 field, short alternative);
public Byte getOrElse(Field.Int8 field, byte alternative);
public Integer getOrElse(Field.Int32 field, int alternative);
public String getOrElse(Field.NullableStr field, String alternative);
public String getOrElse(Field.Str field, String alternative);
public boolean hasField(String name);
public boolean hasField(Field def);
public Byte getByte(BoundField field);
public byte getByte(String name);
public BaseRecords getRecords(String name);
public Short getShort(BoundField field);
public Short getShort(String name);
public Integer getInt(BoundField field);
public Integer getInt(String name);
public Long getUnsignedInt(String name);
public Long getLong(BoundField field);
public Long getLong(String name);
public String getString(BoundField field);
public String getString(String name);
public Boolean getBoolean(BoundField field);
public Boolean getBoolean(String name);
public ByteBuffer getBytes(BoundField field);
public ByteBuffer getBytes(String name);
public int sizeOf();
} |
...