code: public KafkaEndpointBuilder consumerProperties(Map<String, Object> consumerProperties) {
          endpoint.getEndpointConfiguration().setConsumerProperties(consumerProperties);
          return this;
      }
docs: Sets the consumer properties.
  @param consumerProperties
  @return