ConsumerBuilder consumerBuilder = client.newConsumer()
  .topic(CONSUME_TOPIC)
  .subscriptionName(SUBSCRIPTION)
  .subscriptionType(subscriptionSelector(SubscriptionType.Key_Shared))
  .messageListener(hashtagConsumer)
  .patternAutoDiscoveryPeriod(1);