Which two statements about Kafka Connect Single Message Transforms (SMTs) are correct?
(Select two.)
Which two statements are correct about transactions in Kafka?
(Select two.)
You have a Kafka client application that has real-time processing requirements.
Which Kafka metric should you monitor?
You need to consume messages from Kafka using the command-line interface (CLI).
Which command should you use?
Match each configuration parameter with the correct deployment step in installing a Kafka connector.
You are creating a Kafka Streams application to process retail data.
Match the input data streams with the appropriate Kafka Streams object.
What is accomplished by producing data to a topic with a message key?
Which partition assignment minimizes partition movements between two assignments?
Your Kafka cluster has five brokers. The topic t1 on the cluster has:
Two partitions
Replication factor = 4
min.insync.replicas = 3You need strong durability guarantees for messages written to topic t1.You configure a producer acks=all and all the replicas for t1 are in-sync.How many brokers need to acknowledge a message before it is considered committed?
You have a topic t1 with six partitions. You use Kafka Connect to send data from topic t1 in your Kafka cluster to Amazon S3. Kafka Connect is configured for two tasks.
How many partitions will each task process?
What is the default maximum size of a message the Apache Kafka broker can accept?
You are building a system for a retail store selling products to customers.
Which three datasets should you model as a GlobalKTable?
(Select three.)
Match the testing tool with the type of test it is typically used to perform.
Which statement describes the storage location for a sink connector’s offsets?
A producer is configured with the default partitioner. It is sending records to a topic that is configured with five partitions. The record does not contain any key.
What is the result of this?
Your application is consuming from a topic with one consumer group.
The number of running consumers is equal to the number of partitions.
Application logs show that some consumers are leaving the consumer group during peak time, triggering a rebalance. You also notice that your application is processing many duplicates.
You need to stop consumers from leaving the consumer group.
What should you do?
You need to explain the best reason to implement the consumer callback interface ConsumerRebalanceListener prior to a Consumer Group Rebalance.
Which statement is correct?
You create a topic named loT-Data with 10 partitions and replication factor of three.
A producer sends 1 MB messages compressed with Gzip.
Which two statements are true in this scenario?
(Select two.)