Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Use case: multi datacenter, allowing easier subscription to multiple topics prefixed with datacenter names, just by using a pattern subscription.

Public Interfaces

The org.apache.kafka.clients.consumer.KafkaConsumer class will have a new method overload: subscribe(Pattern pattern)

Proposed Changes

The org.apache.kafka.clients.consumer.KafkaConsumer class should have a new method overload: subscribe(Pattern pattern) that calls subscribe(Pattern pattern, ConsumerRebalanceListener listener) with new NoOpConsumerRebalanceListener() as the second argument.

...