What are benefits to gracefully shutting down brokers? (Choose two.)
A broker in the Kafka cluster is currently acting as the Controller.
Which statement is correct?
What is the correct permission check sequence for Kafka ACLs?
A Kafka cluster with three brokers has a topic with 10 partitions and a replication factor set to three. Each partition stores 25 GB data per day and data retention is set to 24 hours.
How much storage will be consumed by the topic on each broker?
Which use cases would benefit most from continuous event stream processing? (Choose three.)
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?
The Consumer property ‘auto offset reset’ determines what to do if there is no valid offset for a Consumer Group.
Which scenario is an example of a valid offset and therefore the ‘auto.offset.reset’ does NOT apply?
If a broker's JVM garbage collection takes too long, what can occur?
Which ksqlDB statement produces data that is persisted into a Kafka topic?
What is the relationship between topics and partitions? (Choose two.)
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 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?
Which statements are correct about partitions? (Choose two.)
Kafka broker supports which Simple Authentication and Security Layer (SASL) mechanisms for authentication? (Choose three.)
An employee in the reporting department needs assistance because their data feed is slowing down. You start by quickly checking the consumer lag for the clients on the data stream.
Which command will allow you to quickly check for lag on the consumers?
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?