public class SamplingOptions extends Object
Modifier and Type | Field and Description |
---|---|
Set<org.apache.kafka.common.TopicPartition> |
assignedTopicPartitions |
org.apache.kafka.common.Cluster |
cluster |
long |
endMs |
Set<org.apache.kafka.common.PartitionInfo> |
partitionAssignment |
long |
startMs |
Constructor and Description |
---|
SamplingOptions(long startMs,
long endMs,
org.apache.kafka.common.Cluster cluster) |
public final long startMs
public final long endMs
public final org.apache.kafka.common.Cluster cluster
public final Set<org.apache.kafka.common.PartitionInfo> partitionAssignment
public final Set<org.apache.kafka.common.TopicPartition> assignedTopicPartitions
public SamplingOptions(long startMs, long endMs, org.apache.kafka.common.Cluster cluster)
startMs
- the minimum milliseconds since unix epoch that a metric we sample should be produced at or after. (i.e inclusive)endMs
- the maximum milliseconds since unix epoch that a metric we sample should be produced before. (i.e exclusive)cluster
- the latest cluster metadata. The sampler will fetch the samples for all partitions in this cluster