Summer Special Limited Time 65% Discount Offer - Ends in 0d 00h 00m 00s - Coupon code: exc65

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"

}

A.

Increase the number of Connect Nodes.

B.

Increase the number of Connect Tasks (tasks max value).

C.

Increase the number of partitions.

D.

Increase the replication factor and increase the number of Connect Tasks.

Kafka broker supports which Simple Authentication and Security Layer (SASL) mechanisms for authentication? (Choose three.)

A.

SASL/PLAIN

B.

SASL/SAML20

C.

SASL/GSSAPI (Kerberos)

D.

SASL/OAUTHBEARER

E.

SASL/OTP

A broker in the Kafka cluster is currently acting as the Controller.

Which statement is correct?

A.

It can have topic partitions.

B.

It is given precedence for replication to and from replica followers.

C.

All consumers are allowed to fetch messages only from this server.

D.

It is responsible for sending leader information to all producers.

You have a cluster with a topic t1 that already has uncompressed messages. A new Producer starts sending messages to t1 with compression enabled.

Which condition would allow this?

A.

If the new Producer is configured to use compression.

B.

Never, because topic t1 already has uncompressed messages.

C.

Only if Kafka is also enabled for encryption.

D.

Only if the new Producer disables batching.

When using Kafka ACLs, when is the resource authorization checked?

A.

Each time the resource is accessed.

B.

The initial time the resource is accessed.

C.

Each time the resource is accessed within the configured authorization interval.

D.

When the client connection is first established.

How can load balancing of Kafka clients across multiple brokers be accomplished?

A.

Partitions

B.

Replicas

C.

Offsets

D.

Connectors