Q: How will you set the retention for the topic named ‚Ä??my-topic‚Ä?? to 1 hour?

retention.ms can be configured at topic level while creating topic or by altering topic. It shouldn't be set at the broker level (log.retention.ms) as this would impact all the topics in the cluster, not just the one we are interested in

Question 1

What data format isn't natively available with the Confluent REST Proxy?

Accepted Answer

Protocol buffers isn't a natively supported type for the Confluent REST Proxy, but you may use the binary format instead

Question 2

A consumer application is using KafkaAvroDeserializer to deserialize Avro messages. What happens if message schema is not present in AvroDeserializer local
cache?

Accepted Answer

First local cache is checked for the message schema. In case of cache miss, schema is pulled from the schema registry. An exception will be thrown in the
Schema Registry does not have the schema (which should never happen if you set it up properly)

Question 3

Where are the dynamic configurations for a topic stored?

Accepted Answer

Dynamic topic configurations are maintained in Zookeeper.

Question 4

A consumer starts and has auto.offset.reset=none, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group has committed
the offset 10 for the topic before. Where will the consumer read from?

Accepted Answer

auto.offset.reset=none means that the consumer will crash if the offsets it's recovering from have been deleted from Kafka, which is the case here, as 10 < 45

Question 5

How will you set the retention for the topic named ‚Ä??my-topic‚Ä?? to 1 hour?

Accepted Answer

retention.ms can be configured at topic level while creating topic or by altering topic. It shouldn't be set at the broker level (log.retention.ms) as this would impact all
the topics in the cluster, not just the one we are interested in

Question 6

What exceptions may be caught by the following producer? (select two) ProducerRecord record = new ProducerRecord<>("topic1", "key1", "value1"); try { producer.send(record); } catch (Exception e) { e.printStackTrace(); } From SurePassExam https://www.surepassexam.com/CCDAK-exam-dumps.html (150 New Questions)

Accepted Answer

These are the client side exceptions that may be encountered before message is sent to the broker, and before a future is returned by the .send() method.

Question 7

If you enable an SSL endpoint in Kafka, what feature of Kafka will be lost?

Accepted Answer

With SSL, messages will need to be encrypted and decrypted, by being first loaded into the JVM, so you lose the zero copy optimization. See more information
herehttps://twitter.com/ijuma/status/1161303431501324293?s=09

Question 8

When using plain JSON data with Connect, you see the following error messageorg.apache.kafka.connect.errors.DataExceptionJsonDeserializer with
schemas.enable requires "schema" and "payload" fields and may not contain additional fields. How will you fix the error?

Accepted Answer

You will need to set the schemas.enable parameters for the converter to false for plain text with no schema.

Question 9

Your producer is producing at a very high rate and the batches are completely full each
time. How can you improve the producer throughput? (select two)

Accepted Answer

batch.size controls how many bytes of data to collect before sending messages to the Kafka broker. Set this as high as possible, without exceeding available
memory. Enabling compression can also help make more compact batches and increase the throughput of your producer. Linger.ms will have no effect as the
batches are already full

Question 10

A Zookeeper ensemble contains 3 servers. Over which ports the members of the ensemble should be able to communicate in default configuration? (select three)

Accepted Answer

2181 - client port, 2888 - peer port, 3888 - leader port