docs: @Override
    public boolean doBuild(TopologyBuilder bldr, Set<String> stageNames) {
      setDefaultNameIfNone(StreamletNamePrefix.CONSUMER, stageNames);
      bldr.setBolt(getName(), new ConsumerSink<>(consumer),
          getNumPartitions()).shuffleGrouping(parent.getName(), parent.getStreamId());
      return true;
    }