Question 71
Clients that connect to a Kafka cluster are required to specify one or more brokers in the bootstrap.servers parameter.
What is the primary advantage of specifying more than one broker?
What is the primary advantage of specifying more than one broker?
Question 72
Which partition assignment minimizes partition movements between two assignments?
Question 73
A stream processing application is consuming from a topic that has five partitions. You run three instances of your application, each with num.streams.threads set to five.
You need to identify the amount of total stream tasks that will be created and the amount that will be actively consuming messages from the input topic.
Which option is correct?
You need to identify the amount of total stream tasks that will be created and the amount that will be actively consuming messages from the input topic.
Which option is correct?
Question 74
Refer to the producer code below. It features a 'Callback' class with a method called 'onCompletion()'. When will the 'onCompletion()' method be Invoked?
producer.send(record, new MyCallback(record));
producer.send(record, new MyCallback(record));
Question 75
You have a topic with four partitions. The application reads from it using two consumers in a single consumer group.
Processing is CPU-bound, and lag is increasing.
What should you do?
Processing is CPU-bound, and lag is increasing.
What should you do?