AGlobalKTableis a replicated, read-only table available in full on all instances. It's best forreference or lookup datasetssuch as:

Product catalog

Customer profiles

Warehouse inventory

FromKafka Streams Developer Guide:

“Use GlobalKTable when you need to perform joins using non-partition-aligned reference data that's small enough to replicate.”

Purchases and transactions are high-throughput, time-sensitive streams, not static reference data.

To ensureexactly-once deliveryand avoid duplicates even during retries:

enable.idempotence=trueensures deduplication on the broker

retries=2147483647allows unlimited retries on retriable errors

max.in.flight.requests.per.connection=5is themaximum value that preserves message order with idempotence

FromKafka Producer Config Docs:

“To achieve exactly-once semantics, set enable.idempotence=true, and max.in.flight.requests.per.connection ≤ 5.”

A is unrelated (consumer-side)

C disables retries

D disables idempotence, leading to duplicates

To increase consumerthroughput, one effective strategy is toincrease the amount of datafetched in each poll by raisingfetch.max.bytesormax.partition.fetch.bytes. This allows each poll to retrieve more records per request, improving processing efficiency.

FromKafka Consumer Config Docs:

“Increasing fetch size allows consumers to retrieve larger batches of messages, improving throughput and reducing request overhead.”

Removing consumers (A) may reduce parallelism.

Manual commit (C) adds complexity, not throughput.

Decreasing session timeout (D) risks unnecessary rebalances.

A409 Conflictresponse in Kafka Connect REST API usually means:

The connector name provided already exists (i.e., a connector with that name is already deployed).

The Kafka Connect cluster is temporarily unavailable to accept new tasks due toa rebalance in progress.

From theConfluent Developer documentationand Kafka Connect REST API spec:

“409 – Conflict. The connector name is already in use or the worker group is in the process of rebalancing and cannot complete the request at this time.”

Option A is incorrect because invalid configurations return400 Bad Request, not 409.

Option B is invalid because Kafka Connect does not have a strict concept of "capacity" that prevents connector creation with a 409.

To change the replication factor of an existing topic, you must perform apartition reassignment, because the replication factor is not directly modifiable via kafka-topics.sh. Thekafka-reassign-partitions.shtool is the official command-line utility to handle partition reassignments, including changing the replication factor.

This tool allows you to generate a reassignment JSON specifying new replica assignments per partition and then apply it.

From official documentation:

“To change the replication factor, use the kafka-reassign-partitions tool to assign the partitions to more or fewer brokers.”

Neither kafka-topics.sh nor kafka-reassign-topics.sh exists for this purpose, and kafka-recreate-topic.sh isnotan official Kafka tool.

For real-time applications, thekey metric to monitor is consumer lag— the difference between thelatest offset on the brokerand thelast committed offset by the consumer.

FromKafka 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.

Frequentrebalancesin a consumer group occur when:

Consumers are too slowand miss heartbeats (A), or

Instances crash or restart, triggering group membership changes (D)

FromKafka Consumer Group Coordination Docs:

“If a consumer fails to send a heartbeat in time (due to slowness or crash), it is removed from the group, causing a rebalance.”

Option B (partition mismatch) affectsload balancing, not rebalance frequency.

Option C (broker storage) doesn't trigger consumer rebalances.