Which configuration determines how many bytes of data are collected before sending messages to the Kafka broker?

• A.batch.size
• B.max.block.size
• C.buffer.memory
• D.send.buffer.bytes

Comment: *

Name: *

Email: *

Verification: *

You need to explain the best reason to implement the consumer callback interface ConsumerRebalanceListener prior to a Consumer Group Rebalance.
Which statement is correct?

• A.Partitions assigned to a consumer may change.
• B.Previous log files are deleted.
• C.Offsets are compacted.
• D.Partition leaders may change.

Comment: *

Name: *

Email: *

Verification: *

The Controller is a broker that is... (select two)

• A.elected by Zookeeper ensemble
• B.is responsible for partition leader election
• C.elected by broker majority
• D.is responsible for consumer group rebalances

Comment: *

Name: *

Email: *

Verification: *

You are sending messages to a Kafka cluster in JSON format and want to add more information related to each message:
* Format of the message payload
* Message creation time
* A globally unique identifier that allows the message to be traced through the systemWhere should this additional information be set?

• A.Header
• B.Key
• C.Value
• D.Broker

Comment: *

Name: *

Email: *

Verification: *

You need to correctly join data from two Kafka topics.
What will allow for the co-partitioning? (Choose 2.)

• A.Both topics have the same value schema.
• B.Both topics have the same key and partitioning strategy.
• C.Both topics have the same number of partitions.
• D.Both topics have the same retention time.

Comment: *

Name: *

Email: *

Verification: *