In Avro, adding an element to an enum without a default is a __ schema evolution
Answer : A
Since Confluent 5.4.0, Avro 1.9.1 is used. Since default value was added to enum complex type , the schema resolution changed from:
(<1.9.1) if both are enums:** if the writer's symbol is not present in the reader's enum, then an error is signalled. **(>=1.9.1) if both are enums:
if the writer's symbol is not present in the reader's enum and the reader has a default value, then that value is used, otherwise an error is signalled.
How will you set the retention for the topic named my-topic to 1 hour?
Answer : C
retention.ms can be configured at topic level while creating topic or by altering topic. It shouldn't be set at the broker level (log.retention.ms) as this would impact all the topics in the cluster, not just the one we are interested in
A consumer has auto.offset.reset=latest, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group never committed offsets for the topic before. Where will the consumer read from?
Answer : A
Latest means that data retrievals will start from where the offsets currently end
Where are KSQL-related data and metadata stored?
Answer : A
metadata is stored in and built from the KSQL command topic. Each KSQL server has its own in-memory version of the metastore.
What is a generic unique id that I can use for messages I receive from a consumer?
Answer : B
(Topic,Partition,Offset) uniquely identifies a message in Kafka
What is not a valid authentication mechanism in Kafka?
Answer : C
Learn more about security herehttps://kafka.apache.org/documentation/#security
You are building a consumer application that processes events from a Kafka topic. What is the most important metric to monitor to ensure real-time processing?
Answer : B
This metric shows the current lag (number of messages behind the broker)