code: protected KafkaQueueFactory<T, ID, DATA> setDefaultKafkaClient(KafkaClient kafkaClient,
              boolean setMyOwnKafkaClient) {
          if (this.defaultKafkaClient != null && myOwnKafkaClient) {
              this.defaultKafkaClient.destroy();
          }
          this.defaultKafkaClient = kafkaClient;
          myOwnKafkaClient = setMyOwnKafkaClient;
          return this;
      }
docs: Setter for {@link #defaultKafkaClient}.
  
  @param kafkaClient
  @param setMyOwnKafkaClient
  @return
  @since 0.7.1