A Kafka administrator notices that their consumers of Topic X are starting to fall behind. The administrator sees that Topic X has four partitions, and the consumer group has two consumers.
Which change can increase the performance of the Consumer Group?
Answer : D
You have an existing topic t1 that you want to delete because there are no more producers writing to it or consumers reading from it.
What is the recommended way to delete the topic?
Answer : A
In certain scenarios, it is necessary to weigh the trade-off between latency and throughput. One method to increase throughput is to configure batching of messages.
In addition to batch.size, what other producer property can be used to accomplish this?
Answer : B
Your organization has a mission-critical Kafka cluster that must be highly available. A Disaster Recovery (DR) cluster has been set up using Replicator, and data is continuously being replicated from source cluster to the DR cluster. However, you notice that the message on offset 1002 on source cluster does not seem to match with offset 1002 on the destination DR cluster.
Which statement is correct?
Answer : C
You are managing a cluster with a large number of topics, and each topic has a lot of partitions. A team wants to significantly increase the number of partitions for some topics.
Which parameters should you check before increasing the partitions?
Answer : C
How can authentication for both internal component traffic and external client traffic be accomplished?
Answer : B
You have a Kafka cluster with topics t1 and t2. In the output below, topic t2 shows Partition 1 with a leader “-1”.
What is the most likely reason for this?
...
$ kafka-topics --zookeeper localhost:2181 --describe --topic t1
Topic: t1 Partition: 0 Leader: 0 Replicas: 0 Isr: 0
$ kafka-topics --zookeeper localhost:2181 --describe --topic t2
Topic: t2 Partition: 0 Leader: 0 Replicas: 0 Isr: 0
Topic: t2 Partition: 1 Leader: -1 Replicas: 1 Isr:
Answer : A
What is the atomic unit of data in Kafka?
Answer : B
A company has an existing Kafka cluster running without SSL/TLS enabled. The customer wants to enable SSL on brokers to secure data in transit, but they would like to give applications connecting to this cluster some time to migrate to using SSL connection instead of putting a hard stop.
Which solution will meet the customer's requirements?
Answer : C
Kafka Connect is running on a two node cluster in distributed mode. The connector is a source connector that pulls data from Postgres tables (users/payment/orders), writes to topics with two partitions, and with replication factor two. The development team notices that the data is lagging behind.
What should be done to reduce the data lag*?
The Connector definition is listed below:
{
"name": "confluent-postgresql-source",
"connector class": "PostgresSource",
"topic.prefix": "postgresql_",
& nbsp;& nbsp;& nbsp;…
"db.name": "postgres",
"table.whitelist": "users.payment.orders”,
"timestamp.column.name": "created_at",
"output.data format": "JSON",
"db.timezone": "UTC",
"tasks.max": "1"
}
Answer : B
Which property in broker configuration specifies that a broker belongs to a particular rack?
Answer : B
Which tool is used for scalably and reliably streaming data between Kafka and other data systems?
Answer : A
What is the primary purpose of Kafka quotas?
Answer : A
What does Kafka replication factor provide? (Choose two.)
Answer : BC
Which out-of-the-box Kafka Authorizer implementation uses ZooKeeper?
Answer : B
Have any questions or issues ? Please dont hesitate to contact us