DEA-C02: SnowPro Advanced — Data EngineerDemo

By Snowflake · Question Mode

QuestionQ54

Official exam objectives/topics

While loading data with the Snowflake Connector for Kafka, the Kafka log file contained the following information:

org.apache.kafka.clients.consumer.CommitFailedException: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member

Which combination of tasks should be used to resolve this issue?

Choose two
  • A Decrease the number of records loaded with each operation to 50.
  • B Disable automatic offset migration by setting it to = FALSE.
  • C Increase the execution timeout to 900000.
  • D Reduce the session.timeout.ms setting to enable faster rebalancing.
  • E Add more partitions to the Kafka topic to prevent rebalancing.
Explanation

This commit failure occurs when message processing takes longer than the configured interval between consumer poll() calls, so Kafka rebalances the consumer group before the offset can be committed. Increasing consumer.max.poll.interval.ms to 900000 allows more processing time, and reducing consumer.max.poll.records to 50 reduces the work in each batch.

Learn more

Community Discussion

No comments yet. Be the first to start the discussion!