To continuously export data from Kafka into a target database, I should use
Answer : C
Kafka Connect Sink is used to export data from Kafka to external databases and Kafka Connect Source is used to import from external databases into Kafka.
Which of the following is not an Avro primitive type?
Answer : D
date is a logical type
An ecommerce wesbite sells some custom made goods. What's the natural way of modeling this data in Kafka streams?
Answer : B
Mostly-static data is modeled as a table whereas business transactions should be modeled as a stream.
How do you create a topic named test with 3 partitions and 3 replicas using the Kafka CLI?
Answer : C
As of Kafka 2.3, the kafka-topics.sh command can take --bootstrap-server localhost:9092 as an argument. You could also use the (now deprecated) option of --zookeeper localhost:2181.
Your streams application is reading from an input topic that has 5 partitions. You run 5 instances of your application, each with num.streams.threads set to 5. How many stream tasks will be created and how many will be active?
Answer : D
One partition is assigned a thread, so only 5 will be active, and 25 threads (i.e. tasks) will be created
A kafka topic has a replication factor of 3 and min.insync.replicas setting of 2. How many brokers can go down before a producer with acks=1 can't produce?
Answer : D
min.insync.replicas does not impact producers when acks=1 (only when acks=all)
What are the requirements for a Kafka broker to connect to a Zookeeper ensemble? (select two)
Answer : B, D
Each broker must have a unique broker id and connect to the same zk ensemble and root zNode