Confluent Certified Administrator for Apache Kafka - CCAAK Exam Questions

QUESTION NO: 1
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"
}

QUESTION NO: 2
A company is setting up a log ingestion use case where they will consume logs from numerous systems. The company wants to tune Kafka for the utmost throughput.
In this scenario, what acknowledgment setting makes the most sense?

QUESTION NO: 3
Which technology can be used to perform event stream processing? (Choose two.)

QUESTION NO: 4
Multiple clients are sharing a Kafka cluster.
As an administrator, how would you ensure that Kafka resources are distributed fairly to all clients?

QUESTION NO: 5
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?

QUESTION NO: 6
Which tool is used for scalably and reliably streaming data between Kafka and other data systems?