Clone of Real ETL and Data Testing Job Interview Questions and Answers

1
Your monitoring dashboard shows that consumer lag is steadily increasing on a critical data pipeline. What does this indicate?* This field is required.CATEGORY: Consumer Lag Monitoring
The consumer is processing messages faster than the producer is sending them
The consumer is falling behind and can't keep up with the incoming message rate
The Kafka broker is running out of disk space
The consumer group is getting balanced across all partitions
Network latency between the consumer and broker has increased significantly
The producer has stopped sending messages and the consumer is catching up
None of the above
2
When you call producer.send() in your application, what happens by default?CATEGORY: SYNC/ASYNC Behavior
The method blocks until the message is written to all replicas
The method returns immediately with a Future object
The message is sent synchronously to the leader broker
The consumer receives the message before the method returns
None of the above
3
You have a topic with 6 partitions and a consumer group with 4 consumers. How will the partitions be distributed?CATEGORY: Partition Assignment
Each consumer gets exactly 1 partition, and 2 partitions remain unassigned
Two consumers get 2 partitions each, and two consumers get 1 partition each
All consumers get 1 partition, and the extra 2 are assigned randomly
The system won't work - you need equal numbers of partitions and consumers
All 4 consumer gets 1 partition each, last consumer gets 3 partitions(2 extra partitions)
None of the above
4
Your data pipeline needs to track when events actually occurred in the source system, not when they arrived at Kafka. Which timestamp type should you configure?* This field is required.CATEGORY: Message Timestamps
CreateTime (producer timestamp)
LogAppendTime (broker timestamp)
ConsumerTime (processing timestamp)
EventTime (custom user timestamp)
ConsunedTime(Consumer received timestamp)
None of the above
5
Your consumer crashes after processing 100 messages but before committing offsets. What happens when it restarts?CATEGORY: Offset Management
It starts from the beginning of the partition
It resumes from where it crashed and processes the next 100 messages
It reprocesses some or all of those 100 messages
The messages are lost and can't be recovered
None of the above
6
Do you want to download answers and validate ?When you press "NEXT" button, you'll see the download link to the PDF (Answers & explainations).
YESNO
Should be Empty: