For real-time applications, the key metric to monitor is consumer lag — the difference between the latest offset on the broker and the last committed offset by the consumer.

From Kafka Monitoring Guide:

“Consumer lag is the most important metric for real-time applications. It tells you how far behind the consumer is from the latest data in Kafka.”

B relates to replication, not client responsiveness.

C tracks group membership stability, not data delay.

D tracks input throughput, not processing latency.

The Apache Kafka producer API is asynchronous by default, and proper error handling requires explicit mechanisms. The official documentation recommends using a callback function with producer.send() to determine whether a record was successfully acknowledged or failed due to an exception. The callback provides access to both RecordMetadata and any exception encountered during sending.

Additionally, certain errors—such as serialization errors or configuration issues—are thrown synchronously when calling producer.send(). These must be handled using a try/catch block that catches KafkaException or its subclasses.

Option A is invalid because ProducerRecord has no status() method. Option C is incorrect because producer.send() returns a Future, not a RecordMetadata object directly.

Thus, combining a callback for asynchronous errors and a try/catch block for synchronous errors is the correct and officially documented approach to ensure reliable producer error handling when using acks=all.

=========================

The ConsumerRebalanceListener lets you handle partition assignments and revocations during rebalances. This is critical for managing offsets, stateful processing, or external transactions.

From Kafka Consumer Rebalance Docs:

“Implementing ConsumerRebalanceListener allows your application to take action before and after partitions are reassigned.”

A is true: It lets your app react when partitions assigned to the consumer change.

B, C, and D are unrelated to consumer rebalancing directly.

According to the official Apache Kafka documentation for Kafka Streams, exactly-once semantics (EOS) are controlled using the processing.guarantee configuration. To ensure that each input record is processed once and only once, and that the results are written atomically to the output topic, Kafka Streams provides built-in EOS support.

The correct and recommended configuration is processing.guarantee=exactly_once_v2, which is the default EOS implementation starting from Kafka 3.0. This mode uses Kafka’s transactional APIs to atomically commit consumer offsets and produce output records within a single transaction. As documented, this prevents duplicates even in the presence of failures, retries, or application restarts.

Option A is incorrect because log compaction does not guarantee exactly-once processing; it only retains the latest record per key. Option B is insufficient because enable.idempotence alone does not handle consumer offset commits or state store consistency in Kafka Streams. Option C is invalid because no such configuration exists in Kafka Streams.

Therefore, setting processing.guarantee=exactly_once_v2 is the only fully correct and officially supported solution for achieving EOS in Kafka Streams applications.

Table → Product, Customers

Stream → Orders_Placed, Shipment_Of_Orders

Tables represent slowly changing, reference data — e.g., customer profiles, product info.

Streams represent real-time event data — e.g., orders placed, shipments processed.

From Kafka Streams Documentation:

“Use KTable for reference datasets, and KStream for event-based processing such as orders or logs.”

The bootstrap.servers setting is used by clients (producers and consumers) to initially connect to the Kafka cluster. It does not need to list all brokers—just a few that are up and reachable. The client will then use the cluster metadata to discover the full broker list.

From Kafka Java Client Configuration Docs:

“This is a list of host/port pairs to use for establishing the initial connection to the Kafka cluster. The client will make use of all servers irrespective of which servers are specified here for bootstrapping.”

Hence, listing multiple brokers provides redundancy and fault tolerance in the event one is down during client startup.

Kafka clients use SLF4J as a logging facade. To redirect Kafka logs to log4j2, you must include the SLF4J binding for log4j2 in your classpath:

“org.apache.logging.log4j:log4j-slf4j-impl bridges SLF4J to Log4j2 so that Kafka's logs integrate into your application's Log4j2 configuration.”

Option A is for Log4j 1.x, which is outdated.

Option C is incorrect; Kafka clients don't include logging bindings.

Option D is insufficient without the SLF4J bridge.