code: protected IQueueMessage<ID, DATA> takeFromQueue() {
          KafkaMessage kMsg = kafkaClient.consumeMessage(consumerGroupId, true, topicName, 1000,
                  TimeUnit.MILLISECONDS);
          return kMsg != null ? deserialize(kMsg.content()) : null;
      }
docs: Takes a message from Kafka queue.
  
  @return
  @since 0.3.3