THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
public class ListConsumerGroupOffsetsOptions extends AbstractOptions<ListConsumerGroupOffsetsOptions> { private List<TopicPartition> topicPartitions = null; private boolean requireStable = false; /** * Set the topic partitions to list as part of the result. * {@code null} includes all topic partitions. * * @param topicPartitions List of topic partitions to include * @return This ListGroupOffsetsOptions */ public ListConsumerGroupOffsetsOptions topicPartitions(List<TopicPartition> topicPartitions) { this.topicPartitions = topicPartitions; return this; } public List<TopicPartition> topicPartitions() { return topicPartitions; } // new API public ListConsumerGroupOffsetsOptions requireStable(final boolean requireStable) { this.requireStable = requireStable; return this; } // new API public boolean shouldRequireStablerequireStable() { return requireStable; } } |
...