org.apache.kafka.common.KafkaException: Unexpected error in commit: This server does not host this topic-partition.

GitHub | edoardocomar | 10 months ago
tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.
  1. 1

    rd_kafka_commit does not notify of non-existing topic

    GitHub | 10 months ago | edoardocomar
    org.apache.kafka.common.KafkaException: Unexpected error in commit: This server does not host this topic-partition.

    Root Cause Analysis

    1. org.apache.kafka.common.KafkaException

      Unexpected error in commit: This server does not host this topic-partition.

      at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetCommitResponseHandler.handle()
    2. org.apache.kafka
      ConsumerCoordinator$OffsetCommitResponseHandler.handle
      1. org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetCommitResponseHandler.handle(ConsumerCoordinator.java:556)
      1 frame