Summer Sale Special 65% Discount Offer - Ends in 0d 00h 00m 00s - Coupon code: ex2p65

Exact2Pass Menu

Question # 4

You are building a system for a retail store selling products to customers.

Which three datasets should you model as a GlobalKTable?

(Select three.)

A.

Inventory of products at a warehouse

B.

All purchases at a retail store occurring in real time

C.

Customer profile information

D.

Log of payment transactions

E.

Catalog of products

Full Access
Question # 5

You are writing to a topic with acks=all.

The producer receives acknowledgments but you notice duplicate messages.

You find that timeouts due to network delay are causing resends.

Which configuration should you use to prevent duplicates?

A.

enable.auto.commit=true

B.

retries=2147483647

max.in.flight.requests.per.connection=5

enable.idempotence=true

C.

retries=0

max.in.flight.requests.per.connection=5

enable.idempotence=true

D.

retries=2147483647

max.in.flight.requests.per.connection=1

enable.idempotence=false

Full Access
Question # 6

You have a consumer group with default configuration settings reading messages from your Kafka cluster.

You need to optimize throughput so the consumer group processes more messages in the same amount of time.

Which change should you make?

A.

Remove some consumers from the consumer group.

B.

Increase the number of bytes the consumers read with each fetch request.

C.

Disable auto commit and have the consumers manually commit offsets.

D.

Decrease the session timeout of each consumer.

Full Access
Question # 7

You are composing a REST request to create a new connector in a running Connect cluster. You invoke POST /connectors with a configuration and receive a 409 (Conflict) response.

What are two reasons for this response? (Select two.)

A.

The connector configuration was invalid, and the response body will expand on the configuration error.

B.

The connect cluster has reached capacity, and new connectors cannot be created without expandingthe cluster.

C.

The Connector already exists in the cluster.

D.

The Connect cluster is in process of rebalancing.

Full Access
Question # 8

Which tool can you use to modify the replication factor of an existing topic?

A.

kafka-reassign-partitions.sh

B.

kafka-recreate-topic.sh

C.

kafka-topics.sh

D.

kafka-reassign-topics.sh

Full Access
Question # 9

You have a Kafka client application that has real-time processing requirements.

Which Kafka metric should you monitor?

A.

Consumer lag between brokers and consumers

B.

Total time to serve requests to replica followers

C.

Consumer heartbeat rate to group coordinator

D.

Aggregate incoming byte rate

Full Access
Question # 10

An application is consuming messages from Kafka.

The application logs show that partitions are frequently being reassigned within the consumer group.

Which two factors may be contributing to this?

(Select two.)

A.

There is a slow consumer processing application.

B.

The number of partitions does not match the number of application instances.

C.

There is a storage issue on the broker.

D.

An instance of the application is crashing and being restarted.

Full Access
Question # 11

Your application is consuming from a topic configured with a deserializer.

It needs to be resilient to badly formatted records ("poison pills"). You surround the poll() call with a try/catch for RecordDeserializationException.

You need to log the bad record, skip it, and continue processing.

Which action should you take in the catch block?

A.

Log the bad record, no other action needed.

B.

Log the bad record and seek the consumer to the offset of the next record.

C.

Log the bad record and call the consumer.skip() method.

D.

Throw a runtime exception to trigger a restart of the application.

Full Access
Question # 12

What is the default maximum size of a message the Apache Kafka broker can accept?

A.

1MB

B.

2MB

C.

5MB

D.

10MB

Full Access
Question # 13

Which partition assignment minimizes partition movements between two assignments?

A.

RoundRobinAssignor

B.

StickyAssignor

C.

RangeAssignor

D.

PartitionAssignor

Full Access
Question # 14

Which statement is true about how exactly-once semantics (EOS) work in Kafka Streams?

A.

Kafka Streams disables log compaction on internal changelog topics to preserve all state changes for potential recovery.

B.

EOS in Kafka Streams relies on transactional producers to atomically commit state updates to changelog topics and output records to Kafka.

C.

Kafka Streams provides EOS by periodically checkpointing state stores and replaying changelogs to recover only unprocessed messages during failure.

D.

EOS in Kafka Streams is implemented by creating a separate Kafka topic for deduplication of all messages processed by the application.

Full Access
Question # 15

You create a topic named stream-logs with:

    A replication factor of 3

    Four partitions

    Messages that are plain logs without a keyHow will messages be distributed across partitions?

A.

The first message will always be written to partition 0.

B.

Messages will be distributed round-robin among all the topic partitions.

C.

All messages will be written to the same log segment.

D.

Messages will be distributed among all the topic partitions with strict ordering.

Full Access
Question # 16

This schema excerpt is an example of which schema format?

package com.mycorp.mynamespace;

message SampleRecord {

int32 Stock = 1;

double Price = 2;

string Product_Name = 3;

}

A.

Avro

B.

Protobuf

C.

JSON Schema

D.

YAML

Full Access
Question # 17

You need to correctly join data from two Kafka topics.

Which two scenarios will allow for co-partitioning?

(Select two.)

A.

Both topics have the same number of partitions.

B.

Both topics have the same key and partitioning strategy.

C.

Both topics have the same value schema.

D.

Both topics have the same retention time.

Full Access
Question # 18

Match the topic configuration setting with the reason the setting affects topic durability.

(You are given settings like unclean.leader.election.enable=false, replication.factor, min.insync.replicas=2)

Full Access