@Test void testNullTokenShouldBeEmpty() { assertTrue(isEmpty(null)); }
public static boolean isEmpty(KafkaTrackingToken token) { return token == null || token.positions.isEmpty(); }
KafkaTrackingToken implements TrackingToken, Serializable { public static boolean isEmpty(KafkaTrackingToken token) { return token == null || token.positions.isEmpty(); } }
KafkaTrackingToken implements TrackingToken, Serializable { public static boolean isEmpty(KafkaTrackingToken token) { return token == null || token.positions.isEmpty(); } private  KafkaTrackingToken(Map<TopicPartition, Long> positions); }
KafkaTrackingToken implements TrackingToken, Serializable { public static boolean isEmpty(KafkaTrackingToken token) { return token == null || token.positions.isEmpty(); } private  KafkaTrackingToken(Map<TopicPartition, Long> positions); @JsonCreator static KafkaTrackingToken newInstance(@JsonProperty("positions") Map<TopicPartition, Long> positions); static KafkaTrackingToken emptyToken(); static boolean isNotEmpty(KafkaTrackingToken token); static boolean isEmpty(KafkaTrackingToken token); @SuppressWarnings("ConstantConditions") static KafkaTrackingToken from(TrackingToken trackingToken); Map<TopicPartition, Long> positions(); KafkaTrackingToken advancedTo(String topic, int partition, long offset); @Override TrackingToken lowerBound(TrackingToken other); @Override TrackingToken upperBound(TrackingToken other); @Override boolean covers(TrackingToken other); @Override boolean equals(Object o); @Override int hashCode(); @Override String toString(); }
KafkaTrackingToken implements TrackingToken, Serializable { public static boolean isEmpty(KafkaTrackingToken token) { return token == null || token.positions.isEmpty(); } private  KafkaTrackingToken(Map<TopicPartition, Long> positions); @JsonCreator static KafkaTrackingToken newInstance(@JsonProperty("positions") Map<TopicPartition, Long> positions); static KafkaTrackingToken emptyToken(); static boolean isNotEmpty(KafkaTrackingToken token); static boolean isEmpty(KafkaTrackingToken token); @SuppressWarnings("ConstantConditions") static KafkaTrackingToken from(TrackingToken trackingToken); Map<TopicPartition, Long> positions(); KafkaTrackingToken advancedTo(String topic, int partition, long offset); @Override TrackingToken lowerBound(TrackingToken other); @Override TrackingToken upperBound(TrackingToken other); @Override boolean covers(TrackingToken other); @Override boolean equals(Object o); @Override int hashCode(); @Override String toString();  }