code: public static <E> TopicProcessor<E> create(String name, int bufferSize) {
  		return TopicProcessor.<E>builder().name(name).bufferSize(bufferSize).build();
  	}
docs: Create a new TopicProcessor using the provided backlog size, with a blockingWait Strategy
  and auto-cancellation. <p> A new Cached ThreadExecutorPool will be implicitly created and will use the passed name to
  qualify the created threads.
  @param name Use a new Cached ExecutorService and assign this name to the created
  threads
  @param bufferSize A Backlog Size to mitigate slow subscribers
  @param <E> Type of processed signals
  @return the fresh TopicProcessor instance