Kafka for Developers - Data Contracts Using Schema Registry - Let's Build AVRO Kafka Consumer

This lecture covers building a Kafka consumer application. It starts with setting up the consumer, including configuring necessary properties like bootstrap servers and deserializers. The lecture then explains subscribing to a topic and polling for data. It details processing consumer records, including decoding byte arrays into greeting instances. Finally, the lecture addresses testing the consumer and resolving logging issues.

What is the primary purpose of creating a new package in the Kafka consumer application?

• To improve the security of the application

• To reduce the size of the application

• To enhance the performance of the application

• To separate the consumer logic from the producer

Which property is NOT required when configuring a Kafka consumer?

• Group ID

• Bootstrap servers

• Key deserializer

• Value serializer

What is the purpose of subscribing to a topic in Kafka?

• To send data to the topic

• To receive data from the topic

• To update data in the topic

• To delete data from the topic

How does the Kafka consumer continuously fetch new data?

• By using a recursive function

• By using a do-while loop

• By using a while loop

• By using a for loop

What is the role of the decode Avro greeting function?

• To encode the greeting into a byte array

• To decode the byte array into a greeting instance

• To log the greeting instance

• To send the greeting instance to the producer

What issue was identified with the logging configuration?

• Logs were not being generated

• Logs were being printed twice

• Logs were too verbose

• Logs were missing important information

What indicates that the Kafka consumer has started successfully?

• The application crashes

• The consumer subscribes to multiple topics

• A log entry stating 'Consumer started'

• A message is sent to the producer