Question 16

What is the primary purpose of Kafka quotas?
  • Question 17

    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 18

    Which out-of-the-box Kafka Authorizer implementation uses ZooKeeper?
  • Question 19

    How can authentication for both internal component traffic and external client traffic be accomplished?