What happens if you write the following code in your producer? producer.send(producerRecord).get()

• A.Compression will be increased
• B.Throughput will be decreased
• C.It will force all brokers in Kafka to acknowledge the producerRecord
• D.Batching will be increased

Comment: *

Name: *

Email: *

Verification: *

Which KSQL queries write to Kafka?

• A.COUNT and JOIN
• B.SHOW STREAMS and EXPLAIN <query> statements
• C.CREATE STREAM WITH <topic> and CREATE TABLE WITH <topic>
• D.CREATE STREAM AS SELECT and CREATE TABLE AS SELECT

Comment: *

Name: *

Email: *

Verification: *

Which of the following errors are retriable from a producer perspective? (select two)

• A.MESSAGE_TOO_LARGE
• B.INVALID_REQUIRED_ACKS
• C.NOT_ENOUGH_REPLICAS
• D.NOT_LEADER_FOR_PARTITION
• E.TOPIC_AUTHORIZATION_FAILED

Comment: *

Name: *

Email: *

Verification: *

The kafka-console-consumer CLI, when used with the default options

• A.uses a random group id
• B.always uses the same group id
• C.does not use a group id

Comment: *

Name: *

Email: *

Verification: *

How can you gracefully make a Kafka consumer to stop immediately polling data from Kafka and gracefully shut down a consumer application?

• A.Call consumer.wakeUp() and catch a WakeUpException
• B.Call consumer.poll() in another thread
• C.Kill the consumer thread

Comment: *

Name: *

Email: *

Verification: *