CCDAK 無料問題集「Confluent Certified Developer for Apache Kafka Certification Examination」

（A）uses a random group id

（B）always uses the same group id

（C）does not use a group id

（A）topic + partition + offset

（B）topic + timestamp

（C）topic + partition + timestamp

（A）Producers can include multiple batches in a single request to a broker.

（B）Producers have a separate background thread for each batch.

（C）Producers can only batch messages of the same size.

（D）Two or more broker failures will automatically disable batching on the producer.

（A）status.storage.topic

（B）plugin.path

（C）offset.storage.topic

（D）group.id

（A）3

（B）None

（C）5

（D）10

（A）An instance of the application is crashing and getting restarted

（B）The number of partitions is not matching the number of application instances.

（C）There is a slow consumer processing application.

（D）There is a storage issue on the broker.

（A）Use a combination of the bank account number and the transaction timestamp as the message key.

（B）Use the bank account number found in the message as the message key.

（C）Use a unique identifier such as a universally unique identifier (UUID) as the message key.

（D）Use the timestamp of the message's arrival as its key.

（A）map

（B）windowing

（C）branch

（D）joins

（A）It provides the ability to wake up dormant brokers.

（B）It provides redundancy in making the initial connection to the Kafka cluster.

（C）It forces clients to enumerate every single broker in the cluster.

（D）It is the mechanism to distribute a topic's partitions across multiple brokers.

（A）fetch.max.wait.ms

（B）max.poll.interval.ms

（C）heartbeat.interval.ms

（D）session.timeout.ms

（A）Call consumer.wakeUp() and catch a WakeUpException

（B）Kill the consumer thread

（C）Call consumer.poll() in another thread

（A）MessageSizeTooLarge exception will be thrown, KafkaProducer retries until the number of retries are exhausted

（B）KafkaProducer divides messages into sizes of message.max.bytes and sends them in order

（C）KafkaProducer divides messages into sizes of max.request.size and sends them in order

（D）MessageSizeTooLarge exception will be thrown, KafkaProducer will not retry and return exception immediately

（A）security.protocol=SASL_PLAINTEXT
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username='myUser' password='myPassword';

（B）security.protocol=SSL
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username='myUser' password='myPassword';

（C）security.protocol=SASL_SSL
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username='myUser' password='myPassword';

（D）security.protocol=PLAINTEXT
sasl.jaas.config=org.apache.kafka.common.security.ssl.TlsLoginModule required username='myUser' password='myPassword';

（A）Existing data will be redistributed across the new number of partitions temporarily increasing cluster load.

（B）Records with the same key could be located in different partitions.

（C）The acknowledgment process will increase latency for producers using acks=all.

（D）Consumers will need to process data from more partitions which will significantly increase consumer lag.

（A）The Kafka ACL does not allow another machine IP

（B）Broker configuration needs to be changed to allow a different producer

（C）The Kafka Broker needs to be rebooted

（D）You cannot copy a producer application from one machine to another

（A）partition

（B）key

（C）key.serializer

（D）bootstrap.servers

（E）value.serializer

（F）value