Confluent CCDAK Exam Practice Questions (P. 1)
- Full Access (70 questions)
- One Year of Premium Access
- Access to one million comments
- Seamless ChatGPT Integration
- Ability to download PDF files
- Anki Flashcard files for revision
- No Captcha & No AdSense
- Advanced Exam Configuration
Question #1
You need to consume messages from Kafka using the command-line interface (CLI).
Which command should you use?
Which command should you use?
- Akafka-console-consumer
- Bkafka-consumer
- Ckafka-get-message
- Dkafka- consume
send
light_mode
delete
Question #2
You are experiencing low throughput from a Java producer. You monitor the Kafka metrics and notice that the metrics for that producer show low I/O thread ratio and low I/O thread wait ratio.
What is the most likely the cause of the slow producer performance?
What is the most likely the cause of the slow producer performance?
- ACompression is enabled.
- BThe producer is sending large batches of messages.
- CThere is a bad data link layer (layer 2) connection from the producer to the cluster.
- DThe producer code has an expensive callback function.
send
light_mode
delete
Question #3
Which configuration is valid for deploying a JDBC Source Connector to read all the rows from orders table and write it to db1-orders topic?
- A{
"name":"jdbc-source",
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"tasks.max": "1",
"connection.url": "jdbc:mysql://mysql:3306/db1?user=user&password=password&useSSL=false",
"topic.prefix": "db1-",
"table.whitelist": "orders"
} - B{
"name":"db1-orders".
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"tasks.max": "1",
"connection.url": "jdbc:mysql://mysql:3306/db1?user=user&password=password&useSSL=false",
"topic.prefix": "db1-",
"table.blacklist": "ord*"
} - C{
"name":"orders-connect",
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"tasks.max": "1",
"connection.url": "jdbc:mysql://mysql:3306/db1",
"topic.whitelist": "orders",
"auto.create": "true"
} - D{
"name":"jdbc-source",
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"tasks.max": "1",
"connection.url": "jdbc:mysql://mysql:3306/db1?user=user&useAutoAuthentication=true", "topic.prefix": "db1-",
"table.whitelist": "orders"
}
send
light_mode
delete
Question #4
You are developing a Kafka Streams application with a complex topology that has multiple sources, processors, sinks, and sub-topologies. You are working in a development environment and do not have access to a real Kafka Cluster or Topic.
You need to perform Unit Test on your Kafka Streams application.
Which should you use?
You need to perform Unit Test on your Kafka Streams application.
Which should you use?
- ATopologyTestDriver
- BMockProducer, MockConsumer
- CTestProducer, TestСonsumer
- DKafkaUnitTestDriver
send
light_mode
delete
Question #5
Which two statements are correct about transactions in Kafka? (Choose two.)
- AAll messages from a failed transaction will be deleted from a Kafka topic.
- BTransactions are only possible when writing messages to a topic with single partition.
- CConsumers can consume both committed and uncommitted transactions.
- DInformation about producers and their transactions is stored in the '__transaction_state' topic.
- ETransactions guarantee at least once delivery of messages.
send
light_mode
delete
All Pages
