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

（A）{"name": "jdbc-source","connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector","tasks.
max": "1","connection.url": "jdbc:mysql://mysql:3306/dbl?user=user&password=pas","topic.prefix":
"dbl-","table.whitelist": "orders"}

（B）{"name": "orders-connect","connector.class": "io.confluent.connect.jdbc.DdbcSourceConnector","tasks.
max": "1","connection.url": "jdbc:mysql://mysql:3306/dbl","topic.whitelist": "orders","auto.create":
"true"}

（C）{"name": "jdbc-source","connector.class": "io.confluent.connect.jdbc.DdbcSourceConnector","tasks.
max": "1","connection.url": "jdbc:mysql://mysql:3306/dbl?user=user&useAutoAuth=true","topic.
prefix": "dbl-","table.whitelist": "orders"}

（D）{"name": "dbl-orders","connector.class": "io.confluent.connect.jdbc.DdbcSourceConnector","tasks.
max": "1","connection.url": "jdbc:mysql://mysql:3306/dbl?user=user&password=pas","topic.prefix":
"dbl-","table.blacklist": "ord*"}

（A）Increase the max.poll.records property of consumers.

（B）Add more consumers to increase the level of parallelism of the processing.

（C）Add more partitions to the topic to increase the level of parallelism of the processing.

（D）Decrease the max.poll.records property of consumers.

（A）Increase the number of Kafka partitions for the topics.

（B）Increase the value of the connector's property tasks.max.

（C）Modify the database schemas to enable horizontal sharding.

（D）Add more Kafka brokers to the cluster.

（A）kafka.controller:type=KafkaController,name=ActiveControllerCount

（B）kafka.controller:type=KafkaController,name=OfflinePartitionsCount

（C）kafka.controller:type=ControllerStats,name=UncleanLeaderElectionsPerSec

（D）kafka.controller:type=KafkaController,name=LastCommittedRecordOffset

（E）kafka.controller:type=KafkaController,name=TopicsToDeleteCount

（A）Specify a key serializer class for the JSON contents of the message's value. Set the value serializer class to null.

（B）Specify a value serializer class for the JSON contents of the message's value. Set the key serializer class to null.

（C）Specify a value serializer class for the JSON contents of the message's value. Set a key serializer for the string value.

（D）Specify a value serializer class for the JSON contents of the message's value. Set the key serializer class to JSON.

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

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

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

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

（A）Repartition one topic to a new topic with the same number of partitions as the other topic (co- partitioning constraint) and use a KStream-KTable join.

（B）Use a GlobalKTable for one of the topics where data does not change frequently and use a KStream- GlobalKTable join.

（C）Use a KStream-KTable join; Kafka Streams will automatically repartition the topics to satisfy the co- partitioning constraint.

（D）Create as many Kafka Streams application instances as the maximum number of partitions of the two topics and use a KStream-KTable join.

（A）The consumer group will not be rebalanced if a consumer leaves the group.

（B）The consumer chooses which partition to read without any assignment from brokers.

（C）It is mandatory to subscribe to a topic before calling assign() to assign partitions.

（D）All topics must have the same number of partitions to use assign() API.

（A）SLF4J implementation for Log4j2 (org.apache.logging.log4j:log4j-slf4j-impl)

（B）SLF4J implementation for Log4j 1.2 (org.slf4j:slf4j-log4j12)

（C）None, the correct dependency will be added transitively by the Kafka client

（D）Just the Log4j2 dependency of the application