DEA-C02: SnowPro Advanced — Data Engineer

By Snowflake · Question Mode

QuestionQ54

VerifiedOfficial 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
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!