如何在ConsumerSekCallback上查找之前分配分区？

Question

我得到以下例外

java.lang.IllegalStateException: No current assignment for partition

在…上

(ConsumerSeekCallback)callback.seek(topic, partition, offset);

来自Kafka文献-

寻找虚空​（java.lang.String主题，int分区，长偏移量）

执行搜索操作。当从ConsumerSekAware调用时。onPartitionsAssigned（映射、ConsumerSekCallback）或来自ConsumerSekAware。onIdleContainer（Map，ConsumerSekCallback）立即对使用者执行搜索。从其他地方调用时，将seek操作排队给使用者。队列搜索将在任何挂起的偏移量提交后发生。当前必须为使用者分配指定的分区。

如果没有分配分区，我该怎么办？

Answer 1

您可以在消费者SeekAware中捕获分配给您的主题-仅在您实际收到主题时执行查找。

如果扩展AbstractConsumerSekAware，则可以将其称为

java prettyprint-override">    /**
     * Return the callback for the specified topic/partition.
     * @param topicPartition the topic/partition.
     * @return the callback (or null if there is no assignment).
     */
    @Nullable
    protected ConsumerSeekCallback getSeekCallbackFor(TopicPartition topicPartition) {
        return this.callbacks.get(topicPartition);
    }