What is the risk of increasing max.in.flight.requests.per.connection while also enabling retries in a producer?
How will you read all the messages from a topic in your KSQL query?
Compaction is enabled for a topic in Kafka by setting log.cleanup.policy=compact. What is true about log compaction?
There are five brokers in a cluster, a topic with 10 partitions and replication factor of 3, and a quota of producer_bytes_rate of 1 MB/sec has been specified for the client. What is the maximum throughput allowed for the client?
To continuously export data from Kafka into a target database, I should use
If a topic has a replication factor of 3...
When using the Confluent Kafka Distribution, where does the schema registry reside?
When auto.create.topics.enable is set to true in Kafka configuration, what are the circumstances under which a Kafka broker automatically creates a topic? (select three)
Which of the following is not an Avro primitive type?
By default, which replica will be elected as a partition leader? (select two)