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