{"id":35180,"date":"2022-01-28T00:53:22","date_gmt":"2022-01-28T00:53:22","guid":{"rendered":"https:\/\/www.dumpsbase.com\/freedumps\/?p=35180"},"modified":"2022-01-28T00:53:25","modified_gmt":"2022-01-28T00:53:25","slug":"confluent-certified-developer-for-apache-kafka-ccdak-exam-real-ccdak-dumps-questions-2022","status":"publish","type":"post","link":"https:\/\/www.dumpsbase.com\/freedumps\/confluent-certified-developer-for-apache-kafka-ccdak-exam-real-ccdak-dumps-questions-2022.html","title":{"rendered":"Confluent Certified Developer for Apache Kafka (CCDAK) Exam Real CCDAK Dumps Questions [2022]"},"content":{"rendered":"\n<p>Being a Confluent Certified Developer for Apache Kafka (CCDAK) certified requires to pass CCDAK exam successfully, but how? DumpsBase has written and verified the CCDAK dumps to provided you with real exam questions and answers. Real CCDAK dumps questions of DumpsBase are provided in two formats:<\/p>\n<ol>\n<li>CCDAK dumps can be read in pdf file, which can be instant downloaded. It is easy to read and use.<\/li>\n<li>CCDAK dumps will be tested in real exam mode with DumpsBase software. The software will be shared for free via mail.<\/li>\n<\/ol>\n<p>At DumpsBase, you can pass your Confluent Certified Developer for Apache Kafka (CCDAK) certification exam with real CCDAK dumps questions in the first attempt.<\/p>\n<h2>CCDAK demo questions are online for checking the high-quality<\/h2>\n<script>\n\t  window.fbAsyncInit = function() {\n\t    FB.init({\n\t      appId            : '622169541470367',\n\t      autoLogAppEvents : true,\n\t      xfbml            : true,\n\t      version          : 'v3.1'\n\t    });\n\t  };\n\t\n\t  (function(d, s, id){\n\t     var js, fjs = d.getElementsByTagName(s)[0];\n\t     if (d.getElementById(id)) {return;}\n\t     js = d.createElement(s); js.id = id;\n\t     js.src = \"https:\/\/connect.facebook.net\/en_US\/sdk.js\";\n\t     fjs.parentNode.insertBefore(js, fjs);\n\t   }(document, 'script', 'facebook-jssdk'));\n\t<\/script><script type=\"text\/javascript\" >\ndocument.addEventListener(\"DOMContentLoaded\", function(event) { \nif(!window.jQuery) alert(\"The important jQuery library is not properly loaded in your site. Your WordPress theme is probably missing the essential wp_head() call. You can switch to another theme and you will see that the plugin works fine and this notice disappears. If you are still not sure what to do you can contact us for help.\");\n});\n<\/script>  \n  \n<div  id=\"watupro_quiz\" class=\"quiz-area single-page-quiz\">\n<p id=\"submittingExam6039\" style=\"display:none;text-align:center;\"><img loading=\"lazy\" decoding=\"async\" src=\"https:\/\/www.dumpsbase.com\/freedumps\/wp-content\/plugins\/watupro\/img\/loading.gif\" width=\"16\" height=\"16\"><\/p>\n\n<div class=\"watupro-exam-description\" id=\"description-quiz-6039\"><\/div>\n\n<form action=\"\" method=\"post\" class=\"quiz-form\" id=\"quiz-6039\"  enctype=\"multipart\/form-data\" >\n<div class='watu-question ' id='question-1' style=';'><div id='questionWrap-1'  class='   watupro-question-id-207658'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>1. <\/span>Where are the dynamic configurations for a topic stored?<\/div><input type='hidden' name='question_id[]' id='qID_1' value='207658' \/><input type='hidden' id='answerType207658' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207658[]' id='answer-id-829426' class='answer   answerof-207658 ' value='829426'   \/><label for='answer-id-829426' id='answer-label-829426' class=' answer'><span>In Zookeeper<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207658[]' id='answer-id-829427' class='answer   answerof-207658 ' value='829427'   \/><label for='answer-id-829427' id='answer-label-829427' class=' answer'><span>In an internal Kafka topic __topic_configuratins<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207658[]' id='answer-id-829428' class='answer   answerof-207658 ' value='829428'   \/><label for='answer-id-829428' id='answer-label-829428' class=' answer'><span>In server.properties<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207658[]' id='answer-id-829429' class='answer   answerof-207658 ' value='829429'   \/><label for='answer-id-829429' id='answer-label-829429' class=' answer'><span>On the Kafka broker file system<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-2' style=';'><div id='questionWrap-2'  class='   watupro-question-id-207659'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>2. <\/span>What happens when broker.rack configuration is provided in broker configuration in Kafka cluster?<\/div><input type='hidden' name='question_id[]' id='qID_2' value='207659' \/><input type='hidden' id='answerType207659' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207659[]' id='answer-id-829430' class='answer   answerof-207659 ' value='829430'   \/><label for='answer-id-829430' id='answer-label-829430' class=' answer'><span>You can use the same broker.id as long as they have different broker.rack configuration<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207659[]' id='answer-id-829431' class='answer   answerof-207659 ' value='829431'   \/><label for='answer-id-829431' id='answer-label-829431' class=' answer'><span>Replicas for a partition are placed in the same rack<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207659[]' id='answer-id-829432' class='answer   answerof-207659 ' value='829432'   \/><label for='answer-id-829432' id='answer-label-829432' class=' answer'><span>Replicas for a partition are spread across different racks<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207659[]' id='answer-id-829433' class='answer   answerof-207659 ' value='829433'   \/><label for='answer-id-829433' id='answer-label-829433' class=' answer'><span>Each rack contains all the topics and partitions, effectively making Kafka highly available<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-3' style=';'><div id='questionWrap-3'  class='   watupro-question-id-207660'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>3. <\/span>What is the disadvantage of request\/response communication?<\/div><input type='hidden' name='question_id[]' id='qID_3' value='207660' \/><input type='hidden' id='answerType207660' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207660[]' id='answer-id-829434' class='answer   answerof-207660 ' value='829434'   \/><label for='answer-id-829434' id='answer-label-829434' class=' answer'><span>Scalability<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207660[]' id='answer-id-829435' class='answer   answerof-207660 ' value='829435'   \/><label for='answer-id-829435' id='answer-label-829435' class=' answer'><span>Reliability<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207660[]' id='answer-id-829436' class='answer   answerof-207660 ' value='829436'   \/><label for='answer-id-829436' id='answer-label-829436' class=' answer'><span>Coupling<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207660[]' id='answer-id-829437' class='answer   answerof-207660 ' value='829437'   \/><label for='answer-id-829437' id='answer-label-829437' class=' answer'><span>Cost<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-4' style=';'><div id='questionWrap-4'  class='   watupro-question-id-207661'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>4. <\/span>is KSQL ANSI SQL compliant?<\/div><input type='hidden' name='question_id[]' id='qID_4' value='207661' \/><input type='hidden' id='answerType207661' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207661[]' id='answer-id-829438' class='answer   answerof-207661 ' value='829438'   \/><label for='answer-id-829438' id='answer-label-829438' class=' answer'><span>Yes<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207661[]' id='answer-id-829439' class='answer   answerof-207661 ' value='829439'   \/><label for='answer-id-829439' id='answer-label-829439' class=' answer'><span>No<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-5' style=';'><div id='questionWrap-5'  class='   watupro-question-id-207662'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>5. <\/span>When using plain JSON data with Connect, you see the following error messageorg.apache.kafka.connect.errors.DataExceptionJsonDeserializer with schemas.enable requires &quot;schema&quot; and &quot;payload&quot; fields and may not contain additional fields . <br \/>\r<br>How will you fix the error?<\/div><input type='hidden' name='question_id[]' id='qID_5' value='207662' \/><input type='hidden' id='answerType207662' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207662[]' id='answer-id-829440' class='answer   answerof-207662 ' value='829440'   \/><label for='answer-id-829440' id='answer-label-829440' class=' answer'><span>Set key.converter, value.converter to JsonConverter and the schema registry url<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207662[]' id='answer-id-829441' class='answer   answerof-207662 ' value='829441'   \/><label for='answer-id-829441' id='answer-label-829441' class=' answer'><span>Use Single Message Transforms to add schema and payload fields in the message<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207662[]' id='answer-id-829442' class='answer   answerof-207662 ' value='829442'   \/><label for='answer-id-829442' id='answer-label-829442' class=' answer'><span>Set key.converter.schemas.enable and value.converter.schemas.enable to false<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207662[]' id='answer-id-829443' class='answer   answerof-207662 ' value='829443'   \/><label for='answer-id-829443' id='answer-label-829443' class=' answer'><span>Set key.converter, value.converter to AvroConverter and the schema registry url<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-6' style=';'><div id='questionWrap-6'  class='   watupro-question-id-207663'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>6. <\/span>There are 3 brokers in the cluster. You want to create a topic with a single partition that is resilient to one broker failure and one broker maintenance . <br \/>\r<br>What is the replication factor will you specify while creating the topic?<\/div><input type='hidden' name='question_id[]' id='qID_6' value='207663' \/><input type='hidden' id='answerType207663' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207663[]' id='answer-id-829444' class='answer   answerof-207663 ' value='829444'   \/><label for='answer-id-829444' id='answer-label-829444' class=' answer'><span>6<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207663[]' id='answer-id-829445' class='answer   answerof-207663 ' value='829445'   \/><label for='answer-id-829445' id='answer-label-829445' class=' answer'><span>3<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207663[]' id='answer-id-829446' class='answer   answerof-207663 ' value='829446'   \/><label for='answer-id-829446' id='answer-label-829446' class=' answer'><span>2<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207663[]' id='answer-id-829447' class='answer   answerof-207663 ' value='829447'   \/><label for='answer-id-829447' id='answer-label-829447' class=' answer'><span>1<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-7' style=';'><div id='questionWrap-7'  class='   watupro-question-id-207664'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>7. <\/span>Two consumers share the same group.id (consumer group id). Each consumer will<\/div><input type='hidden' name='question_id[]' id='qID_7' value='207664' \/><input type='hidden' id='answerType207664' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207664[]' id='answer-id-829448' class='answer   answerof-207664 ' value='829448'   \/><label for='answer-id-829448' id='answer-label-829448' class=' answer'><span>Read mutually exclusive offsets blocks on all the partitions<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207664[]' id='answer-id-829449' class='answer   answerof-207664 ' value='829449'   \/><label for='answer-id-829449' id='answer-label-829449' class=' answer'><span>Read all the data on mutual exclusive partitions<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207664[]' id='answer-id-829450' class='answer   answerof-207664 ' value='829450'   \/><label for='answer-id-829450' id='answer-label-829450' class=' answer'><span>Read all data from all partitions<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-8' style=';'><div id='questionWrap-8'  class='   watupro-question-id-207665'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>8. <\/span>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. <br \/>\r<br>Where will the consumer read from?<\/div><input type='hidden' name='question_id[]' id='qID_8' value='207665' \/><input type='hidden' id='answerType207665' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207665[]' id='answer-id-829451' class='answer   answerof-207665 ' value='829451'   \/><label for='answer-id-829451' id='answer-label-829451' class=' answer'><span>offset 45<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207665[]' id='answer-id-829452' class='answer   answerof-207665 ' value='829452'   \/><label for='answer-id-829452' id='answer-label-829452' class=' answer'><span>offset 10<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207665[]' id='answer-id-829453' class='answer   answerof-207665 ' value='829453'   \/><label for='answer-id-829453' id='answer-label-829453' class=' answer'><span>it will crash<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207665[]' id='answer-id-829454' class='answer   answerof-207665 ' value='829454'   \/><label for='answer-id-829454' id='answer-label-829454' class=' answer'><span>offset 2311<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-9' style=';'><div id='questionWrap-9'  class='   watupro-question-id-207666'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>9. <\/span>A kafka topic has a replication factor of 3 and min.insync.replicas setting of 2 . <br \/>\r<br>How many brokers can go down before a producer with acks=all can't produce?<\/div><input type='hidden' name='question_id[]' id='qID_9' value='207666' \/><input type='hidden' id='answerType207666' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207666[]' id='answer-id-829455' class='answer   answerof-207666 ' value='829455'   \/><label for='answer-id-829455' id='answer-label-829455' class=' answer'><span>0<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207666[]' id='answer-id-829456' class='answer   answerof-207666 ' value='829456'   \/><label for='answer-id-829456' id='answer-label-829456' class=' answer'><span>2<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207666[]' id='answer-id-829457' class='answer   answerof-207666 ' value='829457'   \/><label for='answer-id-829457' id='answer-label-829457' class=' answer'><span>1<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207666[]' id='answer-id-829458' class='answer   answerof-207666 ' value='829458'   \/><label for='answer-id-829458' id='answer-label-829458' class=' answer'><span>3<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-10' style=';'><div id='questionWrap-10'  class='   watupro-question-id-207667'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>10. <\/span>Where are KSQL-related data and metadata stored?<\/div><input type='hidden' name='question_id[]' id='qID_10' value='207667' \/><input type='hidden' id='answerType207667' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207667[]' id='answer-id-829459' class='answer   answerof-207667 ' value='829459'   \/><label for='answer-id-829459' id='answer-label-829459' class=' answer'><span>Kafka Topics<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207667[]' id='answer-id-829460' class='answer   answerof-207667 ' value='829460'   \/><label for='answer-id-829460' id='answer-label-829460' class=' answer'><span>Zookeeper<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207667[]' id='answer-id-829461' class='answer   answerof-207667 ' value='829461'   \/><label for='answer-id-829461' id='answer-label-829461' class=' answer'><span>PostgreSQL database<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207667[]' id='answer-id-829462' class='answer   answerof-207667 ' value='829462'   \/><label for='answer-id-829462' id='answer-label-829462' class=' answer'><span>Schema Registry<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-11' style=';'><div id='questionWrap-11'  class='   watupro-question-id-207668'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>11. <\/span>You want to sink data from a Kafka topic to S3 using Kafka Connect. There are 10 brokers in the cluster, the topic has 2 partitions with replication factor of 3 . <br \/>\r<br>How many tasks will you configure for the S3 connector?<\/div><input type='hidden' name='question_id[]' id='qID_11' value='207668' \/><input type='hidden' id='answerType207668' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207668[]' id='answer-id-829463' class='answer   answerof-207668 ' value='829463'   \/><label for='answer-id-829463' id='answer-label-829463' class=' answer'><span>10<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207668[]' id='answer-id-829464' class='answer   answerof-207668 ' value='829464'   \/><label for='answer-id-829464' id='answer-label-829464' class=' answer'><span>6<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207668[]' id='answer-id-829465' class='answer   answerof-207668 ' value='829465'   \/><label for='answer-id-829465' id='answer-label-829465' class=' answer'><span>3<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207668[]' id='answer-id-829466' class='answer   answerof-207668 ' value='829466'   \/><label for='answer-id-829466' id='answer-label-829466' class=' answer'><span>2<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-12' style=';'><div id='questionWrap-12'  class='   watupro-question-id-207669'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>12. <\/span>To enhance compression, I can increase the chances of batching by using<\/div><input type='hidden' name='question_id[]' id='qID_12' value='207669' \/><input type='hidden' id='answerType207669' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207669[]' id='answer-id-829467' class='answer   answerof-207669 ' value='829467'   \/><label for='answer-id-829467' id='answer-label-829467' class=' answer'><span>acks=all<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207669[]' id='answer-id-829468' class='answer   answerof-207669 ' value='829468'   \/><label for='answer-id-829468' id='answer-label-829468' class=' answer'><span>linger.ms=20<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207669[]' id='answer-id-829469' class='answer   answerof-207669 ' value='829469'   \/><label for='answer-id-829469' id='answer-label-829469' class=' answer'><span>batch.size=65536<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207669[]' id='answer-id-829470' class='answer   answerof-207669 ' value='829470'   \/><label for='answer-id-829470' id='answer-label-829470' class=' answer'><span>max.message.size=10MB<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-13' style=';'><div id='questionWrap-13'  class='   watupro-question-id-207670'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>13. <\/span>How can you gracefully make a Kafka consumer to stop immediately polling data from Kafka and gracefully shut down a consumer application?<\/div><input type='hidden' name='question_id[]' id='qID_13' value='207670' \/><input type='hidden' id='answerType207670' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207670[]' id='answer-id-829471' class='answer   answerof-207670 ' value='829471'   \/><label for='answer-id-829471' id='answer-label-829471' class=' answer'><span>Call consumer.wakeUp() and catch a WakeUpException<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207670[]' id='answer-id-829472' class='answer   answerof-207670 ' value='829472'   \/><label for='answer-id-829472' id='answer-label-829472' class=' answer'><span>Call consumer.poll() in another thread<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207670[]' id='answer-id-829473' class='answer   answerof-207670 ' value='829473'   \/><label for='answer-id-829473' id='answer-label-829473' class=' answer'><span>Kill the consumer thread<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-14' style=';'><div id='questionWrap-14'  class='   watupro-question-id-207671'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>14. <\/span>StreamsBuilder builder = new StreamsBuilder(); <br \/>\r<br>KStream&lt;String, String&gt; textLines = builder.stream(&quot;word-count-input&quot;); <br \/>\r<br>KTable&lt;String, Long&gt; wordCounts = textLines <br \/>\r<br>.mapValues(textLine -&gt; textLine.toLowerCase()) <br \/>\r<br>.flatMapValues(textLine -&gt; Arrays.asList(textLine.split(&quot;W+&quot;))) <br \/>\r<br>.selectKey((key, word) -&gt; word) <br \/>\r<br>.groupByKey() <br \/>\r<br>.count(Materialized.as(&quot;Counts&quot;)); <br \/>\r<br>wordCounts.toStream().to(&quot;word-count-output&quot;, Produced.with(Serdes.String(), Serdes.Long())); <br \/>\r<br>builder.build(); <br \/>\r<br>What is an adequate topic configuration for the topic word-count-output?<\/div><input type='hidden' name='question_id[]' id='qID_14' value='207671' \/><input type='hidden' id='answerType207671' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207671[]' id='answer-id-829474' class='answer   answerof-207671 ' value='829474'   \/><label for='answer-id-829474' id='answer-label-829474' class=' answer'><span>max.message.bytes=10000000<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207671[]' id='answer-id-829475' class='answer   answerof-207671 ' value='829475'   \/><label for='answer-id-829475' id='answer-label-829475' class=' answer'><span>cleanup.policy=delete<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207671[]' id='answer-id-829476' class='answer   answerof-207671 ' value='829476'   \/><label for='answer-id-829476' id='answer-label-829476' class=' answer'><span>compression.type=lz4<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207671[]' id='answer-id-829477' class='answer   answerof-207671 ' value='829477'   \/><label for='answer-id-829477' id='answer-label-829477' class=' answer'><span>cleanup.policy=compact<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-15' style=';'><div id='questionWrap-15'  class='   watupro-question-id-207672'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>15. <\/span>Where are the ACLs stored in a Kafka cluster by default?<\/div><input type='hidden' name='question_id[]' id='qID_15' value='207672' \/><input type='hidden' id='answerType207672' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207672[]' id='answer-id-829478' class='answer   answerof-207672 ' value='829478'   \/><label for='answer-id-829478' id='answer-label-829478' class=' answer'><span>Inside the broker's data directory<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207672[]' id='answer-id-829479' class='answer   answerof-207672 ' value='829479'   \/><label for='answer-id-829479' id='answer-label-829479' class=' answer'><span>Under Zookeeper node \/kafka-acl\/<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207672[]' id='answer-id-829480' class='answer   answerof-207672 ' value='829480'   \/><label for='answer-id-829480' id='answer-label-829480' class=' answer'><span>In Kafka topic __kafka_acls<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207672[]' id='answer-id-829481' class='answer   answerof-207672 ' value='829481'   \/><label for='answer-id-829481' id='answer-label-829481' class=' answer'><span>Inside the Zookeeper's data directory<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-16' style=';'><div id='questionWrap-16'  class='   watupro-question-id-207673'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>16. <\/span>What kind of delivery guarantee this consumer offers? <br \/>\r<br>while (true) { <br \/>\r<br>ConsumerRecords&lt;String, String&gt; records = consumer.poll(100); <br \/>\r<br>try { <br \/>\r<br>consumer.commitSync(); <br \/>\r<br>} catch (CommitFailedException e) { log.error(&quot;commit failed&quot;, e) <br \/>\r<br>} <br \/>\r<br>for (ConsumerRecord&lt;String, String&gt; record records) <br \/>\r<br>{ <br \/>\r<br>System.out.printf(&quot;topic = %s, partition = %s, offset = %d, customer = %s, country = %s <br \/>\r<br>&quot;, <br \/>\r<br>record.topic(), record.partition(), record.offset(), record.key(), record.value()); <br \/>\r<br>} <br \/>\r<br>}<\/div><input type='hidden' name='question_id[]' id='qID_16' value='207673' \/><input type='hidden' id='answerType207673' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207673[]' id='answer-id-829482' class='answer   answerof-207673 ' value='829482'   \/><label for='answer-id-829482' id='answer-label-829482' class=' answer'><span>Exactly-once<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207673[]' id='answer-id-829483' class='answer   answerof-207673 ' value='829483'   \/><label for='answer-id-829483' id='answer-label-829483' class=' answer'><span>At-least-once<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207673[]' id='answer-id-829484' class='answer   answerof-207673 ' value='829484'   \/><label for='answer-id-829484' id='answer-label-829484' class=' answer'><span>At-most-once<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-17' style=';'><div id='questionWrap-17'  class='   watupro-question-id-207674'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>17. <\/span>The exactly once guarantee in the Kafka Streams is for which flow of data?<\/div><input type='hidden' name='question_id[]' id='qID_17' value='207674' \/><input type='hidden' id='answerType207674' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207674[]' id='answer-id-829485' class='answer   answerof-207674 ' value='829485'   \/><label for='answer-id-829485' id='answer-label-829485' class=' answer'><span>Kafka =&gt; Kafka<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207674[]' id='answer-id-829486' class='answer   answerof-207674 ' value='829486'   \/><label for='answer-id-829486' id='answer-label-829486' class=' answer'><span>Kafka =&gt; External<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207674[]' id='answer-id-829487' class='answer   answerof-207674 ' value='829487'   \/><label for='answer-id-829487' id='answer-label-829487' class=' answer'><span>External =&gt; Kafka<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-18' style=';'><div id='questionWrap-18'  class='   watupro-question-id-207675'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>18. <\/span>You are using JDBC source connector to copy data from a table to Kafka topic. There is one connector created with max.tasks equal to 2 deployed on a cluster of 3 workers . <br \/>\r<br>How many tasks are launched?<\/div><input type='hidden' name='question_id[]' id='qID_18' value='207675' \/><input type='hidden' id='answerType207675' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207675[]' id='answer-id-829488' class='answer   answerof-207675 ' value='829488'   \/><label for='answer-id-829488' id='answer-label-829488' class=' answer'><span>3<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207675[]' id='answer-id-829489' class='answer   answerof-207675 ' value='829489'   \/><label for='answer-id-829489' id='answer-label-829489' class=' answer'><span>2<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207675[]' id='answer-id-829490' class='answer   answerof-207675 ' value='829490'   \/><label for='answer-id-829490' id='answer-label-829490' class=' answer'><span>1<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207675[]' id='answer-id-829491' class='answer   answerof-207675 ' value='829491'   \/><label for='answer-id-829491' id='answer-label-829491' class=' answer'><span>6<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-19' style=';'><div id='questionWrap-19'  class='   watupro-question-id-207676'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>19. <\/span>You want to perform table lookups against a KTable everytime a new record is received from the KStream . <br \/>\r<br>What is the output of KStream-KTable join?<\/div><input type='hidden' name='question_id[]' id='qID_19' value='207676' \/><input type='hidden' id='answerType207676' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207676[]' id='answer-id-829492' class='answer   answerof-207676 ' value='829492'   \/><label for='answer-id-829492' id='answer-label-829492' class=' answer'><span>KTable<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207676[]' id='answer-id-829493' class='answer   answerof-207676 ' value='829493'   \/><label for='answer-id-829493' id='answer-label-829493' class=' answer'><span>GlobalKTable<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207676[]' id='answer-id-829494' class='answer   answerof-207676 ' value='829494'   \/><label for='answer-id-829494' id='answer-label-829494' class=' answer'><span>You choose between KStream or KTable<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207676[]' id='answer-id-829495' class='answer   answerof-207676 ' value='829495'   \/><label for='answer-id-829495' id='answer-label-829495' class=' answer'><span>Kstream<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-20' style=';'><div id='questionWrap-20'  class='   watupro-question-id-207677'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>20. <\/span>You are doing complex calculations using a machine learning framework on records fetched from a Kafka topic. It takes more about 6 minutes to process a record batch, and he consumer enters rebalances even though it's still running . <br \/>\r<br>How can you improve this scenario?<\/div><input type='hidden' name='question_id[]' id='qID_20' value='207677' \/><input type='hidden' id='answerType207677' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207677[]' id='answer-id-829496' class='answer   answerof-207677 ' value='829496'   \/><label for='answer-id-829496' id='answer-label-829496' class=' answer'><span>Increase max.poll.interval.ms to 600000<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207677[]' id='answer-id-829497' class='answer   answerof-207677 ' value='829497'   \/><label for='answer-id-829497' id='answer-label-829497' class=' answer'><span>Increase heartbeat.interval.ms to 600000<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207677[]' id='answer-id-829498' class='answer   answerof-207677 ' value='829498'   \/><label for='answer-id-829498' id='answer-label-829498' class=' answer'><span>Increase session.timeout.ms to 600000<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207677[]' id='answer-id-829499' class='answer   answerof-207677 ' value='829499'   \/><label for='answer-id-829499' id='answer-label-829499' class=' answer'><span>Add consumers to the consumer group and kill them right away<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-21' style=';'><div id='questionWrap-21'  class='   watupro-question-id-207678'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>21. <\/span>Which actions will trigger partition rebalance for a consumer group? (select three)<\/div><input type='hidden' name='question_id[]' id='qID_21' value='207678' \/><input type='hidden' id='answerType207678' value='checkbox'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207678[]' id='answer-id-829500' class='answer   answerof-207678 ' value='829500'   \/><label for='answer-id-829500' id='answer-label-829500' class=' answer'><span>Increase partitions of a topic<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207678[]' id='answer-id-829501' class='answer   answerof-207678 ' value='829501'   \/><label for='answer-id-829501' id='answer-label-829501' class=' answer'><span>Remove a broker from the cluster<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207678[]' id='answer-id-829502' class='answer   answerof-207678 ' value='829502'   \/><label for='answer-id-829502' id='answer-label-829502' class=' answer'><span>Add a new consumer to consumer group<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207678[]' id='answer-id-829503' class='answer   answerof-207678 ' value='829503'   \/><label for='answer-id-829503' id='answer-label-829503' class=' answer'><span>A consumer in a consumer group shuts down \r\nAdd a broker to the cluster<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-22' style=';'><div id='questionWrap-22'  class='   watupro-question-id-207679'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>22. <\/span>Which of the following setting increases the chance of batching for a Kafka Producer?<\/div><input type='hidden' name='question_id[]' id='qID_22' value='207679' \/><input type='hidden' id='answerType207679' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207679[]' id='answer-id-829504' class='answer   answerof-207679 ' value='829504'   \/><label for='answer-id-829504' id='answer-label-829504' class=' answer'><span>Increase batch.size<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207679[]' id='answer-id-829505' class='answer   answerof-207679 ' value='829505'   \/><label for='answer-id-829505' id='answer-label-829505' class=' answer'><span>Increase message.max.bytes<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207679[]' id='answer-id-829506' class='answer   answerof-207679 ' value='829506'   \/><label for='answer-id-829506' id='answer-label-829506' class=' answer'><span>Increase the number of producer threads<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207679[]' id='answer-id-829507' class='answer   answerof-207679 ' value='829507'   \/><label for='answer-id-829507' id='answer-label-829507' class=' answer'><span>Increase linger.ms<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-23' style=';'><div id='questionWrap-23'  class='   watupro-question-id-207680'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>23. <\/span>What data format isn't natively available with the Confluent REST Proxy?<\/div><input type='hidden' name='question_id[]' id='qID_23' value='207680' \/><input type='hidden' id='answerType207680' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207680[]' id='answer-id-829508' class='answer   answerof-207680 ' value='829508'   \/><label for='answer-id-829508' id='answer-label-829508' class=' answer'><span>avro<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207680[]' id='answer-id-829509' class='answer   answerof-207680 ' value='829509'   \/><label for='answer-id-829509' id='answer-label-829509' class=' answer'><span>binary<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207680[]' id='answer-id-829510' class='answer   answerof-207680 ' value='829510'   \/><label for='answer-id-829510' id='answer-label-829510' class=' answer'><span>protobuf<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207680[]' id='answer-id-829511' class='answer   answerof-207680 ' value='829511'   \/><label for='answer-id-829511' id='answer-label-829511' class=' answer'><span>json<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-24' style=';'><div id='questionWrap-24'  class='   watupro-question-id-207681'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>24. <\/span>You are using JDBC source connector to copy data from 2 tables to two Kafka topics. There is one connector created with max.tasks equal to 2 deployed on a cluster of 3 workers . <br \/>\r<br>How many tasks are launched?<\/div><input type='hidden' name='question_id[]' id='qID_24' value='207681' \/><input type='hidden' id='answerType207681' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207681[]' id='answer-id-829512' class='answer   answerof-207681 ' value='829512'   \/><label for='answer-id-829512' id='answer-label-829512' class=' answer'><span>6<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207681[]' id='answer-id-829513' class='answer   answerof-207681 ' value='829513'   \/><label for='answer-id-829513' id='answer-label-829513' class=' answer'><span>1<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207681[]' id='answer-id-829514' class='answer   answerof-207681 ' value='829514'   \/><label for='answer-id-829514' id='answer-label-829514' class=' answer'><span>2<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207681[]' id='answer-id-829515' class='answer   answerof-207681 ' value='829515'   \/><label for='answer-id-829515' id='answer-label-829515' class=' answer'><span>3<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-25' style=';'><div id='questionWrap-25'  class='   watupro-question-id-207682'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>25. <\/span>To import data from external databases, I should use<\/div><input type='hidden' name='question_id[]' id='qID_25' value='207682' \/><input type='hidden' id='answerType207682' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207682[]' id='answer-id-829516' class='answer   answerof-207682 ' value='829516'   \/><label for='answer-id-829516' id='answer-label-829516' class=' answer'><span>Confluent REST Proxy<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207682[]' id='answer-id-829517' class='answer   answerof-207682 ' value='829517'   \/><label for='answer-id-829517' id='answer-label-829517' class=' answer'><span>Kafka Connect Sink<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207682[]' id='answer-id-829518' class='answer   answerof-207682 ' value='829518'   \/><label for='answer-id-829518' id='answer-label-829518' class=' answer'><span>Kafka Streams<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207682[]' id='answer-id-829519' class='answer   answerof-207682 ' value='829519'   \/><label for='answer-id-829519' id='answer-label-829519' class=' answer'><span>Kafka Connect Source<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-26' style=';'><div id='questionWrap-26'  class='   watupro-question-id-207683'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>26. <\/span>What is a generic unique id that I can use for messages I receive from a consumer?<\/div><input type='hidden' name='question_id[]' id='qID_26' value='207683' \/><input type='hidden' id='answerType207683' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207683[]' id='answer-id-829520' class='answer   answerof-207683 ' value='829520'   \/><label for='answer-id-829520' id='answer-label-829520' class=' answer'><span>topic + partition + timestamp<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207683[]' id='answer-id-829521' class='answer   answerof-207683 ' value='829521'   \/><label for='answer-id-829521' id='answer-label-829521' class=' answer'><span>topic + partition + offset<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207683[]' id='answer-id-829522' class='answer   answerof-207683 ' value='829522'   \/><label for='answer-id-829522' id='answer-label-829522' class=' answer'><span>topic + timestamp<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-27' style=';'><div id='questionWrap-27'  class='   watupro-question-id-207684'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>27. <\/span>What happens if you write the following code in your producer? <br \/>\r<br>producer.send(producerRecord).get()<\/div><input type='hidden' name='question_id[]' id='qID_27' value='207684' \/><input type='hidden' id='answerType207684' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207684[]' id='answer-id-829523' class='answer   answerof-207684 ' value='829523'   \/><label for='answer-id-829523' id='answer-label-829523' class=' answer'><span>Compression will be increased<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207684[]' id='answer-id-829524' class='answer   answerof-207684 ' value='829524'   \/><label for='answer-id-829524' id='answer-label-829524' class=' answer'><span>Throughput will be decreased<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207684[]' id='answer-id-829525' class='answer   answerof-207684 ' value='829525'   \/><label for='answer-id-829525' id='answer-label-829525' class=' answer'><span>It will force all brokers in Kafka to acknowledge the producerRecord<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207684[]' id='answer-id-829526' class='answer   answerof-207684 ' value='829526'   \/><label for='answer-id-829526' id='answer-label-829526' class=' answer'><span>Batching will be increased<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-28' style=';'><div id='questionWrap-28'  class='   watupro-question-id-207685'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>28. <\/span>Compaction is enabled for a topic in Kafka by setting log.cleanup.policy=compact . <br \/>\r<br>What is true about log compaction?<\/div><input type='hidden' name='question_id[]' id='qID_28' value='207685' \/><input type='hidden' id='answerType207685' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207685[]' id='answer-id-829527' class='answer   answerof-207685 ' value='829527'   \/><label for='answer-id-829527' id='answer-label-829527' class=' answer'><span>After cleanup, only one message per key is retained with the first value<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207685[]' id='answer-id-829528' class='answer   answerof-207685 ' value='829528'   \/><label for='answer-id-829528' id='answer-label-829528' class=' answer'><span>Each message stored in the topic is compressed<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207685[]' id='answer-id-829529' class='answer   answerof-207685 ' value='829529'   \/><label for='answer-id-829529' id='answer-label-829529' class=' answer'><span>Kafka automatically de-duplicates incoming messages based on key hashes<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207685[]' id='answer-id-829530' class='answer   answerof-207685 ' value='829530'   \/><label for='answer-id-829530' id='answer-label-829530' class=' answer'><span>After cleanup, only one message per key is retained with the latest value \r\nCompaction changes the offset of messages<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-29' style=';'><div id='questionWrap-29'  class='   watupro-question-id-207686'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>29. <\/span>Which of these joins does not require input topics to be sharing the same number of partitions?<\/div><input type='hidden' name='question_id[]' id='qID_29' value='207686' \/><input type='hidden' id='answerType207686' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207686[]' id='answer-id-829531' class='answer   answerof-207686 ' value='829531'   \/><label for='answer-id-829531' id='answer-label-829531' class=' answer'><span>KStream-KTable join<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207686[]' id='answer-id-829532' class='answer   answerof-207686 ' value='829532'   \/><label for='answer-id-829532' id='answer-label-829532' class=' answer'><span>KStream-KStream join<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207686[]' id='answer-id-829533' class='answer   answerof-207686 ' value='829533'   \/><label for='answer-id-829533' id='answer-label-829533' class=' answer'><span>KStream-GlobalKTable<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207686[]' id='answer-id-829534' class='answer   answerof-207686 ' value='829534'   \/><label for='answer-id-829534' id='answer-label-829534' class=' answer'><span>KTable-KTable join<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-30' style=';'><div id='questionWrap-30'  class='   watupro-question-id-207687'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>30. <\/span>How often is log compaction evaluated?<\/div><input type='hidden' name='question_id[]' id='qID_30' value='207687' \/><input type='hidden' id='answerType207687' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207687[]' id='answer-id-829535' class='answer   answerof-207687 ' value='829535'   \/><label for='answer-id-829535' id='answer-label-829535' class=' answer'><span>Every time a new partition is created<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207687[]' id='answer-id-829536' class='answer   answerof-207687 ' value='829536'   \/><label for='answer-id-829536' id='answer-label-829536' class=' answer'><span>Every time a segment is closed<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207687[]' id='answer-id-829537' class='answer   answerof-207687 ' value='829537'   \/><label for='answer-id-829537' id='answer-label-829537' class=' answer'><span>Every time a message is sent to Kafka<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207687[]' id='answer-id-829538' class='answer   answerof-207687 ' value='829538'   \/><label for='answer-id-829538' id='answer-label-829538' class=' answer'><span>Every time a message is flushed to disk<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-31' style=';'><div id='questionWrap-31'  class='   watupro-question-id-207688'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>31. <\/span>A Zookeeper ensemble contains 3 servers. <br \/>\r<br>Over which ports the members of the ensemble should be able to communicate in default configuration? (select three)<\/div><input type='hidden' name='question_id[]' id='qID_31' value='207688' \/><input type='hidden' id='answerType207688' value='checkbox'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207688[]' id='answer-id-829539' class='answer   answerof-207688 ' value='829539'   \/><label for='answer-id-829539' id='answer-label-829539' class=' answer'><span>2181<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207688[]' id='answer-id-829540' class='answer   answerof-207688 ' value='829540'   \/><label for='answer-id-829540' id='answer-label-829540' class=' answer'><span>3888<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207688[]' id='answer-id-829541' class='answer   answerof-207688 ' value='829541'   \/><label for='answer-id-829541' id='answer-label-829541' class=' answer'><span>443<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207688[]' id='answer-id-829542' class='answer   answerof-207688 ' value='829542'   \/><label for='answer-id-829542' id='answer-label-829542' class=' answer'><span>2888<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207688[]' id='answer-id-829543' class='answer   answerof-207688 ' value='829543'   \/><label for='answer-id-829543' id='answer-label-829543' class=' answer'><span>9092<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207688[]' id='answer-id-829544' class='answer   answerof-207688 ' value='829544'   \/><label for='answer-id-829544' id='answer-label-829544' class=' answer'><span>80<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-32' style=';'><div id='questionWrap-32'  class='   watupro-question-id-207689'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>32. <\/span>A client connects to a broker in the cluster and sends a fetch request for a partition in a topic. It gets an exception Not Leader For Partition Exception in the response . <br \/>\r<br>How does client handle this situation?<\/div><input type='hidden' name='question_id[]' id='qID_32' value='207689' \/><input type='hidden' id='answerType207689' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207689[]' id='answer-id-829545' class='answer   answerof-207689 ' value='829545'   \/><label for='answer-id-829545' id='answer-label-829545' class=' answer'><span>Get the Broker id from Zookeeper that is hosting the leader replica and send request to it<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207689[]' id='answer-id-829546' class='answer   answerof-207689 ' value='829546'   \/><label for='answer-id-829546' id='answer-label-829546' class=' answer'><span>Send metadata request to the same broker for the topic and select the broker hosting the leader replica<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207689[]' id='answer-id-829547' class='answer   answerof-207689 ' value='829547'   \/><label for='answer-id-829547' id='answer-label-829547' class=' answer'><span>Send metadata request to Zookeeper for the topic and select the broker hosting the leader replica<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207689[]' id='answer-id-829548' class='answer   answerof-207689 ' value='829548'   \/><label for='answer-id-829548' id='answer-label-829548' class=' answer'><span>Send fetch request to each Broker in the cluster<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-33' style=';'><div id='questionWrap-33'  class='   watupro-question-id-207690'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>33. <\/span>If I supply the setting compression.type=snappy to my producer, what will happen? (select two)<\/div><input type='hidden' name='question_id[]' id='qID_33' value='207690' \/><input type='hidden' id='answerType207690' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207690[]' id='answer-id-829549' class='answer   answerof-207690 ' value='829549'   \/><label for='answer-id-829549' id='answer-label-829549' class=' answer'><span>The Kafka brokers have to de-compress the data<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207690[]' id='answer-id-829550' class='answer   answerof-207690 ' value='829550'   \/><label for='answer-id-829550' id='answer-label-829550' class=' answer'><span>The Kafka brokers have to compress the data<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207690[]' id='answer-id-829551' class='answer   answerof-207690 ' value='829551'   \/><label for='answer-id-829551' id='answer-label-829551' class=' answer'><span>The Consumers have to de-compress the data<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207690[]' id='answer-id-829552' class='answer   answerof-207690 ' value='829552'   \/><label for='answer-id-829552' id='answer-label-829552' class=' answer'><span>The Consumers have to compress the data<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207690[]' id='answer-id-829553' class='answer   answerof-207690 ' value='829553'   \/><label for='answer-id-829553' id='answer-label-829553' class=' answer'><span>The Producers have to compress the data<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-34' style=';'><div id='questionWrap-34'  class='   watupro-question-id-207691'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>34. <\/span>If I produce to a topic that does not exist, and the broker setting auto.create.topic.enable=true, what will happen?<\/div><input type='hidden' name='question_id[]' id='qID_34' value='207691' \/><input type='hidden' id='answerType207691' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207691[]' id='answer-id-829554' class='answer   answerof-207691 ' value='829554'   \/><label for='answer-id-829554' id='answer-label-829554' class=' answer'><span>Kafka will automatically create the topic with 1 partition and 1 replication factor<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207691[]' id='answer-id-829555' class='answer   answerof-207691 ' value='829555'   \/><label for='answer-id-829555' id='answer-label-829555' class=' answer'><span>Kafka will automatically create the topic with the indicated producer settings num.partitions and default.replication.factor<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207691[]' id='answer-id-829556' class='answer   answerof-207691 ' value='829556'   \/><label for='answer-id-829556' id='answer-label-829556' class=' answer'><span>Kafka will automatically create the topic with the broker settings num.partitions and default.replication.factor<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207691[]' id='answer-id-829557' class='answer   answerof-207691 ' value='829557'   \/><label for='answer-id-829557' id='answer-label-829557' class=' answer'><span>Kafka will automatically create the topic with num.partitions=#of brokers and replication.factor=3<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-35' style=';'><div id='questionWrap-35'  class='   watupro-question-id-207692'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>35. <\/span>How will you read all the messages from a topic in your KSQL query?<\/div><input type='hidden' name='question_id[]' id='qID_35' value='207692' \/><input type='hidden' id='answerType207692' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207692[]' id='answer-id-829558' class='answer   answerof-207692 ' value='829558'   \/><label for='answer-id-829558' id='answer-label-829558' class=' answer'><span>KSQL reads from the beginning of a topic, by default.<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207692[]' id='answer-id-829559' class='answer   answerof-207692 ' value='829559'   \/><label for='answer-id-829559' id='answer-label-829559' class=' answer'><span>KSQL reads from the end of a topic. This cannot be changed.<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207692[]' id='answer-id-829560' class='answer   answerof-207692 ' value='829560'   \/><label for='answer-id-829560' id='answer-label-829560' class=' answer'><span>Use KSQL CLI to set auto.offset.reset property to earliest<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-36' style=';'><div id='questionWrap-36'  class='   watupro-question-id-207693'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>36. <\/span>The kafka-console-consumer CLI, when used with the default options<\/div><input type='hidden' name='question_id[]' id='qID_36' value='207693' \/><input type='hidden' id='answerType207693' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207693[]' id='answer-id-829561' class='answer   answerof-207693 ' value='829561'   \/><label for='answer-id-829561' id='answer-label-829561' class=' answer'><span>uses a random group id<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207693[]' id='answer-id-829562' class='answer   answerof-207693 ' value='829562'   \/><label for='answer-id-829562' id='answer-label-829562' class=' answer'><span>always uses the same group id<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207693[]' id='answer-id-829563' class='answer   answerof-207693 ' value='829563'   \/><label for='answer-id-829563' id='answer-label-829563' class=' answer'><span>does not use a group id<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-37' style=';'><div id='questionWrap-37'  class='   watupro-question-id-207694'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>37. <\/span>A producer is sending messages with null key to a topic with 6 partitions using the DefaultPartitioner. Where will the messages be stored?<\/div><input type='hidden' name='question_id[]' id='qID_37' value='207694' \/><input type='hidden' id='answerType207694' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207694[]' id='answer-id-829564' class='answer   answerof-207694 ' value='829564'   \/><label for='answer-id-829564' id='answer-label-829564' class=' answer'><span>Partition 5<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207694[]' id='answer-id-829565' class='answer   answerof-207694 ' value='829565'   \/><label for='answer-id-829565' id='answer-label-829565' class=' answer'><span>Any of the topic partitions<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207694[]' id='answer-id-829566' class='answer   answerof-207694 ' value='829566'   \/><label for='answer-id-829566' id='answer-label-829566' class=' answer'><span>The partition for the null key<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207694[]' id='answer-id-829567' class='answer   answerof-207694 ' value='829567'   \/><label for='answer-id-829567' id='answer-label-829567' class=' answer'><span>Partition 0<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-38' style=';'><div id='questionWrap-38'  class='   watupro-question-id-207695'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>38. <\/span>Which of the following Kafka Streams operators are stateless? (select all that apply)<\/div><input type='hidden' name='question_id[]' id='qID_38' value='207695' \/><input type='hidden' id='answerType207695' value='checkbox'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207695[]' id='answer-id-829568' class='answer   answerof-207695 ' value='829568'   \/><label for='answer-id-829568' id='answer-label-829568' class=' answer'><span>map<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207695[]' id='answer-id-829569' class='answer   answerof-207695 ' value='829569'   \/><label for='answer-id-829569' id='answer-label-829569' class=' answer'><span>filter<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207695[]' id='answer-id-829570' class='answer   answerof-207695 ' value='829570'   \/><label for='answer-id-829570' id='answer-label-829570' class=' answer'><span>flatmap<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207695[]' id='answer-id-829571' class='answer   answerof-207695 ' value='829571'   \/><label for='answer-id-829571' id='answer-label-829571' class=' answer'><span>branch<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207695[]' id='answer-id-829572' class='answer   answerof-207695 ' value='829572'   \/><label for='answer-id-829572' id='answer-label-829572' class=' answer'><span>groupBy<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207695[]' id='answer-id-829573' class='answer   answerof-207695 ' value='829573'   \/><label for='answer-id-829573' id='answer-label-829573' class=' answer'><span>aggregate<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-39' style=';'><div id='questionWrap-39'  class='   watupro-question-id-207696'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>39. <\/span>Suppose you have 6 brokers and you decide to create a topic with 10 partitions and a replication factor of 3. The brokers 0 and 1 are on rack A, the brokers 2 and 3 are on rack B, and the brokers 4 and 5 are on rack C. If the leader for partition 0 is on broker 4, and the first replica is on broker 2, which broker can host the last replica? (select two)<\/div><input type='hidden' name='question_id[]' id='qID_39' value='207696' \/><input type='hidden' id='answerType207696' value='checkbox'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207696[]' id='answer-id-829574' class='answer   answerof-207696 ' value='829574'   \/><label for='answer-id-829574' id='answer-label-829574' class=' answer'><span>6<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207696[]' id='answer-id-829575' class='answer   answerof-207696 ' value='829575'   \/><label for='answer-id-829575' id='answer-label-829575' class=' answer'><span>1<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207696[]' id='answer-id-829576' class='answer   answerof-207696 ' value='829576'   \/><label for='answer-id-829576' id='answer-label-829576' class=' answer'><span>2<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207696[]' id='answer-id-829577' class='answer   answerof-207696 ' value='829577'   \/><label for='answer-id-829577' id='answer-label-829577' class=' answer'><span>5<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207696[]' id='answer-id-829578' class='answer   answerof-207696 ' value='829578'   \/><label for='answer-id-829578' id='answer-label-829578' class=' answer'><span>0<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207696[]' id='answer-id-829579' class='answer   answerof-207696 ' value='829579'   \/><label for='answer-id-829579' id='answer-label-829579' class=' answer'><span>3<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-40' style=';'><div id='questionWrap-40'  class='   watupro-question-id-207697'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>40. <\/span>Your topic is log compacted and you are sending a message with the key K and value null . <br \/>\r<br>What will happen?<\/div><input type='hidden' name='question_id[]' id='qID_40' value='207697' \/><input type='hidden' id='answerType207697' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207697[]' id='answer-id-829580' class='answer   answerof-207697 ' value='829580'   \/><label for='answer-id-829580' id='answer-label-829580' class=' answer'><span>The broker will delete all messages with the key K upon cleanup<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207697[]' id='answer-id-829581' class='answer   answerof-207697 ' value='829581'   \/><label for='answer-id-829581' id='answer-label-829581' class=' answer'><span>The producer will throw a Runtime exception<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207697[]' id='answer-id-829582' class='answer   answerof-207697 ' value='829582'   \/><label for='answer-id-829582' id='answer-label-829582' class=' answer'><span>The broker will delete the message with the key K and null value only upon cleanup<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207697[]' id='answer-id-829583' class='answer   answerof-207697 ' value='829583'   \/><label for='answer-id-829583' id='answer-label-829583' class=' answer'><span>The message will get ignored by the Kafka broker<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-41' style=';'><div id='questionWrap-41'  class='   watupro-question-id-207698'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>41. <\/span>A kafka topic has a replication factor of 3 and min.insync.replicas setting of 1 . <br \/>\r<br>What is the maximum number of brokers that can be down so that a producer with acks=all can still produce to the topic?<\/div><input type='hidden' name='question_id[]' id='qID_41' value='207698' \/><input type='hidden' id='answerType207698' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207698[]' id='answer-id-829584' class='answer   answerof-207698 ' value='829584'   \/><label for='answer-id-829584' id='answer-label-829584' class=' answer'><span>3<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207698[]' id='answer-id-829585' class='answer   answerof-207698 ' value='829585'   \/><label for='answer-id-829585' id='answer-label-829585' class=' answer'><span>0<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207698[]' id='answer-id-829586' class='answer   answerof-207698 ' value='829586'   \/><label for='answer-id-829586' id='answer-label-829586' class=' answer'><span>2<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207698[]' id='answer-id-829587' class='answer   answerof-207698 ' value='829587'   \/><label for='answer-id-829587' id='answer-label-829587' class=' answer'><span>1<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-42' style=';'><div id='questionWrap-42'  class='   watupro-question-id-207699'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>42. <\/span>You have a Kafka cluster and all the topics have a replication factor of 3. One intern at your company stopped a broker, and accidentally deleted all the data of that broker on the disk . <br \/>\r<br>What will happen if the broker is restarted?<\/div><input type='hidden' name='question_id[]' id='qID_42' value='207699' \/><input type='hidden' id='answerType207699' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207699[]' id='answer-id-829588' class='answer   answerof-207699 ' value='829588'   \/><label for='answer-id-829588' id='answer-label-829588' class=' answer'><span>The broker will start, and other topics will also be deleted as the broker data on the disk got deleted<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207699[]' id='answer-id-829589' class='answer   answerof-207699 ' value='829589'   \/><label for='answer-id-829589' id='answer-label-829589' class=' answer'><span>The broker will start, and won't be online until all the data it needs to have is replicated from other leaders<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207699[]' id='answer-id-829590' class='answer   answerof-207699 ' value='829590'   \/><label for='answer-id-829590' id='answer-label-829590' class=' answer'><span>The broker will crash<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207699[]' id='answer-id-829591' class='answer   answerof-207699 ' value='829591'   \/><label for='answer-id-829591' id='answer-label-829591' class=' answer'><span>The broker will start, and won't have any data. If the broker comes leader, we have a data loss<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-43' style=';'><div id='questionWrap-43'  class='   watupro-question-id-207700'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>43. <\/span>A consumer application is using KafkaAvroDeserializer to deserialize Avro messages . <br \/>\r<br>What happens if message schema is not present in AvroDeserializer local cache?<\/div><input type='hidden' name='question_id[]' id='qID_43' value='207700' \/><input type='hidden' id='answerType207700' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207700[]' id='answer-id-829592' class='answer   answerof-207700 ' value='829592'   \/><label for='answer-id-829592' id='answer-label-829592' class=' answer'><span>Throws SerializationException<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207700[]' id='answer-id-829593' class='answer   answerof-207700 ' value='829593'   \/><label for='answer-id-829593' id='answer-label-829593' class=' answer'><span>Fails silently<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207700[]' id='answer-id-829594' class='answer   answerof-207700 ' value='829594'   \/><label for='answer-id-829594' id='answer-label-829594' class=' answer'><span>Throws DeserializationException<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207700[]' id='answer-id-829595' class='answer   answerof-207700 ' value='829595'   \/><label for='answer-id-829595' id='answer-label-829595' class=' answer'><span>Fetches schema from Schema Registry<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-44' style=';'><div id='questionWrap-44'  class='   watupro-question-id-207701'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>44. <\/span>In the Kafka consumer metrics it is observed that fetch-rate is very high and each fetch is small . <br \/>\r<br>What steps will you take to increase throughput?<\/div><input type='hidden' name='question_id[]' id='qID_44' value='207701' \/><input type='hidden' id='answerType207701' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207701[]' id='answer-id-829596' class='answer   answerof-207701 ' value='829596'   \/><label for='answer-id-829596' id='answer-label-829596' class=' answer'><span>Increase fetch.max.wait<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207701[]' id='answer-id-829597' class='answer   answerof-207701 ' value='829597'   \/><label for='answer-id-829597' id='answer-label-829597' class=' answer'><span>Increase fetch.max.bytes<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207701[]' id='answer-id-829598' class='answer   answerof-207701 ' value='829598'   \/><label for='answer-id-829598' id='answer-label-829598' class=' answer'><span>Decrease fetch.max.bytes<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207701[]' id='answer-id-829599' class='answer   answerof-207701 ' value='829599'   \/><label for='answer-id-829599' id='answer-label-829599' class=' answer'><span>Decrease fetch.min.bytes<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207701[]' id='answer-id-829600' class='answer   answerof-207701 ' value='829600'   \/><label for='answer-id-829600' id='answer-label-829600' class=' answer'><span>Increase fetch.min.bytes<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-45' style=';'><div id='questionWrap-45'  class='   watupro-question-id-207702'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>45. <\/span>In Avro, removing or adding a field that has a default is a __ schema evolution<\/div><input type='hidden' name='question_id[]' id='qID_45' value='207702' \/><input type='hidden' id='answerType207702' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207702[]' id='answer-id-829601' class='answer   answerof-207702 ' value='829601'   \/><label for='answer-id-829601' id='answer-label-829601' class=' answer'><span>full<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207702[]' id='answer-id-829602' class='answer   answerof-207702 ' value='829602'   \/><label for='answer-id-829602' id='answer-label-829602' class=' answer'><span>backward<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207702[]' id='answer-id-829603' class='answer   answerof-207702 ' value='829603'   \/><label for='answer-id-829603' id='answer-label-829603' class=' answer'><span>breaking<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207702[]' id='answer-id-829604' class='answer   answerof-207702 ' value='829604'   \/><label for='answer-id-829604' id='answer-label-829604' class=' answer'><span>forward<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-46' style=';'><div id='questionWrap-46'  class='   watupro-question-id-207703'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>46. <\/span>You have a consumer group of 12 consumers and when a consumer gets killed by the process management system, rather abruptly, it does not trigger a graceful shutdown of your consumer. Therefore, it takes up to 10 seconds for a rebalance to happen. The business would like to have a 3 seconds rebalance time . <br \/>\r<br>What should you do? (select two)<\/div><input type='hidden' name='question_id[]' id='qID_46' value='207703' \/><input type='hidden' id='answerType207703' value='checkbox'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207703[]' id='answer-id-829605' class='answer   answerof-207703 ' value='829605'   \/><label for='answer-id-829605' id='answer-label-829605' class=' answer'><span>Increase session.timeout.ms<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207703[]' id='answer-id-829606' class='answer   answerof-207703 ' value='829606'   \/><label for='answer-id-829606' id='answer-label-829606' class=' answer'><span>Decrease session.timeout.ms<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207703[]' id='answer-id-829607' class='answer   answerof-207703 ' value='829607'   \/><label for='answer-id-829607' id='answer-label-829607' class=' answer'><span>Increase heartbeat.interval.ms<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207703[]' id='answer-id-829608' class='answer   answerof-207703 ' value='829608'   \/><label for='answer-id-829608' id='answer-label-829608' class=' answer'><span>decrease max.poll.interval.ms<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207703[]' id='answer-id-829609' class='answer   answerof-207703 ' value='829609'   \/><label for='answer-id-829609' id='answer-label-829609' class=' answer'><span>increase max.poll.interval.ms<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207703[]' id='answer-id-829610' class='answer   answerof-207703 ' value='829610'   \/><label for='answer-id-829610' id='answer-label-829610' class=' answer'><span>Decrease heartbeat.interval.ms<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-47' style=';'><div id='questionWrap-47'  class='   watupro-question-id-207704'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>47. <\/span>A consumer starts and has auto.offset.reset=latest, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group has committed the offset 643 for the topic before. <br \/>\r<br>Where will the consumer read from?<\/div><input type='hidden' name='question_id[]' id='qID_47' value='207704' \/><input type='hidden' id='answerType207704' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207704[]' id='answer-id-829611' class='answer   answerof-207704 ' value='829611'   \/><label for='answer-id-829611' id='answer-label-829611' class=' answer'><span>it will crash<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207704[]' id='answer-id-829612' class='answer   answerof-207704 ' value='829612'   \/><label for='answer-id-829612' id='answer-label-829612' class=' answer'><span>offset 2311<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207704[]' id='answer-id-829613' class='answer   answerof-207704 ' value='829613'   \/><label for='answer-id-829613' id='answer-label-829613' class=' answer'><span>offset 643<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207704[]' id='answer-id-829614' class='answer   answerof-207704 ' value='829614'   \/><label for='answer-id-829614' id='answer-label-829614' class=' answer'><span>offset 45<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-48' style=';'><div id='questionWrap-48'  class='   watupro-question-id-207705'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>48. <\/span>You are receiving orders from different customer in an &quot;orders&quot; topic with multiple partitions. Each message has the customer name as the key. There is a special customer named ABC that generates a lot of orders and you would like to reserve a partition exclusively for ABC. The rest of the message should be distributed among other partitions . <br \/>\r<br>How can this be achieved?<\/div><input type='hidden' name='question_id[]' id='qID_48' value='207705' \/><input type='hidden' id='answerType207705' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207705[]' id='answer-id-829615' class='answer   answerof-207705 ' value='829615'   \/><label for='answer-id-829615' id='answer-label-829615' class=' answer'><span>Add metadata to the producer record<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207705[]' id='answer-id-829616' class='answer   answerof-207705 ' value='829616'   \/><label for='answer-id-829616' id='answer-label-829616' class=' answer'><span>Create a custom partitioner<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207705[]' id='answer-id-829617' class='answer   answerof-207705 ' value='829617'   \/><label for='answer-id-829617' id='answer-label-829617' class=' answer'><span>All messages with the same key will go the same partition, but the same partition may have messages with different keys. It is not possible to reserve<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207705[]' id='answer-id-829618' class='answer   answerof-207705 ' value='829618'   \/><label for='answer-id-829618' id='answer-label-829618' class=' answer'><span>Define a Kafka Broker routing rule<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-49' style=';'><div id='questionWrap-49'  class='   watupro-question-id-207706'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>49. <\/span>A Zookeeper ensemble contains 5 servers . <br \/>\r<br>What is the maximum number of servers that can go missing and the ensemble still run?<\/div><input type='hidden' name='question_id[]' id='qID_49' value='207706' \/><input type='hidden' id='answerType207706' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207706[]' id='answer-id-829619' class='answer   answerof-207706 ' value='829619'   \/><label for='answer-id-829619' id='answer-label-829619' class=' answer'><span>3<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207706[]' id='answer-id-829620' class='answer   answerof-207706 ' value='829620'   \/><label for='answer-id-829620' id='answer-label-829620' class=' answer'><span>4<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207706[]' id='answer-id-829621' class='answer   answerof-207706 ' value='829621'   \/><label for='answer-id-829621' id='answer-label-829621' class=' answer'><span>2<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207706[]' id='answer-id-829622' class='answer   answerof-207706 ' value='829622'   \/><label for='answer-id-829622' id='answer-label-829622' class=' answer'><span>1<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-50' style=';'><div id='questionWrap-50'  class='   watupro-question-id-207707'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>50. <\/span>If I want to send binary data through the REST proxy, it needs to be base64 encoded . <br \/>\r<br>Which component needs to encode the binary data into base 64?<\/div><input type='hidden' name='question_id[]' id='qID_50' value='207707' \/><input type='hidden' id='answerType207707' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207707[]' id='answer-id-829623' class='answer   answerof-207707 ' value='829623'   \/><label for='answer-id-829623' id='answer-label-829623' class=' answer'><span>The Producer<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207707[]' id='answer-id-829624' class='answer   answerof-207707 ' value='829624'   \/><label for='answer-id-829624' id='answer-label-829624' class=' answer'><span>The Kafka Broker<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207707[]' id='answer-id-829625' class='answer   answerof-207707 ' value='829625'   \/><label for='answer-id-829625' id='answer-label-829625' class=' answer'><span>Zookeeper<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207707[]' id='answer-id-829626' class='answer   answerof-207707 ' value='829626'   \/><label for='answer-id-829626' id='answer-label-829626' class=' answer'><span>The REST Proxy<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-51' style=';'><div id='questionWrap-51'  class='   watupro-question-id-207708'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>51. <\/span>Which of the following is not an Avro primitive type?<\/div><input type='hidden' name='question_id[]' id='qID_51' value='207708' \/><input type='hidden' id='answerType207708' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207708[]' id='answer-id-829627' class='answer   answerof-207708 ' value='829627'   \/><label for='answer-id-829627' id='answer-label-829627' class=' answer'><span>string<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207708[]' id='answer-id-829628' class='answer   answerof-207708 ' value='829628'   \/><label for='answer-id-829628' id='answer-label-829628' class=' answer'><span>long<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207708[]' id='answer-id-829629' class='answer   answerof-207708 ' value='829629'   \/><label for='answer-id-829629' id='answer-label-829629' class=' answer'><span>int<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207708[]' id='answer-id-829630' class='answer   answerof-207708 ' value='829630'   \/><label for='answer-id-829630' id='answer-label-829630' class=' answer'><span>date<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207708[]' id='answer-id-829631' class='answer   answerof-207708 ' value='829631'   \/><label for='answer-id-829631' id='answer-label-829631' class=' answer'><span>null<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-52' style=';'><div id='questionWrap-52'  class='   watupro-question-id-207709'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>52. <\/span>An ecommerce website maintains two topics - a high volume &quot;purchase&quot; topic with 5 partitions and low volume &quot;customer&quot; topic with 3 partitions. You would like to do a stream-table join of these topics . <br \/>\r<br>How should you proceed?<\/div><input type='hidden' name='question_id[]' id='qID_52' value='207709' \/><input type='hidden' id='answerType207709' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207709[]' id='answer-id-829632' class='answer   answerof-207709 ' value='829632'   \/><label for='answer-id-829632' id='answer-label-829632' class=' answer'><span>Repartition the purchase topic to have 3 partitions<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207709[]' id='answer-id-829633' class='answer   answerof-207709 ' value='829633'   \/><label for='answer-id-829633' id='answer-label-829633' class=' answer'><span>Repartition customer topic to have 5 partitions<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207709[]' id='answer-id-829634' class='answer   answerof-207709 ' value='829634'   \/><label for='answer-id-829634' id='answer-label-829634' class=' answer'><span>Model customer as a GlobalKTable<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207709[]' id='answer-id-829635' class='answer   answerof-207709 ' value='829635'   \/><label for='answer-id-829635' id='answer-label-829635' class=' answer'><span>Do a KStream \/ KTable join after a repartition step<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-53' style=';'><div id='questionWrap-53'  class='   watupro-question-id-207710'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>53. <\/span>A topic &quot;sales&quot; is being produced to in the Americas region. You are mirroring this topic using Mirror Maker to the European region. From there, you are only reading the topic for analytics purposes . <br \/>\r<br>What kind of mirroring is this?<\/div><input type='hidden' name='question_id[]' id='qID_53' value='207710' \/><input type='hidden' id='answerType207710' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207710[]' id='answer-id-829636' class='answer   answerof-207710 ' value='829636'   \/><label for='answer-id-829636' id='answer-label-829636' class=' answer'><span>Passive-Passive<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207710[]' id='answer-id-829637' class='answer   answerof-207710 ' value='829637'   \/><label for='answer-id-829637' id='answer-label-829637' class=' answer'><span>Active-Active<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207710[]' id='answer-id-829638' class='answer   answerof-207710 ' value='829638'   \/><label for='answer-id-829638' id='answer-label-829638' class=' answer'><span>Active-Passive<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-54' style=';'><div id='questionWrap-54'  class='   watupro-question-id-207711'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>54. <\/span>In Kafka, every broker... (select three)<\/div><input type='hidden' name='question_id[]' id='qID_54' value='207711' \/><input type='hidden' id='answerType207711' value='checkbox'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207711[]' id='answer-id-829639' class='answer   answerof-207711 ' value='829639'   \/><label for='answer-id-829639' id='answer-label-829639' class=' answer'><span>contains all the topics and all the partitions<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207711[]' id='answer-id-829640' class='answer   answerof-207711 ' value='829640'   \/><label for='answer-id-829640' id='answer-label-829640' class=' answer'><span>knows all the metadata for all topics and partitions<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207711[]' id='answer-id-829641' class='answer   answerof-207711 ' value='829641'   \/><label for='answer-id-829641' id='answer-label-829641' class=' answer'><span>is a controller<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207711[]' id='answer-id-829642' class='answer   answerof-207711 ' value='829642'   \/><label for='answer-id-829642' id='answer-label-829642' class=' answer'><span>knows the metadata for the topics and partitions it has on its disk<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207711[]' id='answer-id-829643' class='answer   answerof-207711 ' value='829643'   \/><label for='answer-id-829643' id='answer-label-829643' class=' answer'><span>is a bootstrap broker<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207711[]' id='answer-id-829644' class='answer   answerof-207711 ' value='829644'   \/><label for='answer-id-829644' id='answer-label-829644' class=' answer'><span>contains only a subset of the topics and the partitions<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-55' style=';'><div id='questionWrap-55'  class='   watupro-question-id-207712'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>55. <\/span>What is true about partitions? (select two)<\/div><input type='hidden' name='question_id[]' id='qID_55' value='207712' \/><input type='hidden' id='answerType207712' value='checkbox'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207712[]' id='answer-id-829645' class='answer   answerof-207712 ' value='829645'   \/><label for='answer-id-829645' id='answer-label-829645' class=' answer'><span>A broker can have a partition and its replica on its disk<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207712[]' id='answer-id-829646' class='answer   answerof-207712 ' value='829646'   \/><label for='answer-id-829646' id='answer-label-829646' class=' answer'><span>You cannot have more partitions than the number of brokers in your cluster<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207712[]' id='answer-id-829647' class='answer   answerof-207712 ' value='829647'   \/><label for='answer-id-829647' id='answer-label-829647' class=' answer'><span>A broker can have different partitions numbers for the same topic on its disk<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207712[]' id='answer-id-829648' class='answer   answerof-207712 ' value='829648'   \/><label for='answer-id-829648' id='answer-label-829648' class=' answer'><span>Only out of sync replicas are replicas, the remaining partitions that are in sync are also leader<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='checkbox' name='answer-207712[]' id='answer-id-829649' class='answer   answerof-207712 ' value='829649'   \/><label for='answer-id-829649' id='answer-label-829649' class=' answer'><span>A partition has one replica that is a leader, while the other replicas are followers<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-56' style=';'><div id='questionWrap-56'  class='   watupro-question-id-207713'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>56. <\/span>A consumer has auto.offset.reset=latest, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group never committed offsets for the topic before. <br \/>\r<br>Where will the consumer read from?<\/div><input type='hidden' name='question_id[]' id='qID_56' value='207713' \/><input type='hidden' id='answerType207713' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207713[]' id='answer-id-829650' class='answer   answerof-207713 ' value='829650'   \/><label for='answer-id-829650' id='answer-label-829650' class=' answer'><span>offset 2311<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207713[]' id='answer-id-829651' class='answer   answerof-207713 ' value='829651'   \/><label for='answer-id-829651' id='answer-label-829651' class=' answer'><span>offset 0<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207713[]' id='answer-id-829652' class='answer   answerof-207713 ' value='829652'   \/><label for='answer-id-829652' id='answer-label-829652' class=' answer'><span>offset 45<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207713[]' id='answer-id-829653' class='answer   answerof-207713 ' value='829653'   \/><label for='answer-id-829653' id='answer-label-829653' class=' answer'><span>it will crash<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-57' style=';'><div id='questionWrap-57'  class='   watupro-question-id-207714'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>57. <\/span>You are running a Kafka Streams application in a Docker container managed by Kubernetes, and upon application restart, it takes a long time for the docker container to replicate the state and get back to processing the data . <br \/>\r<br>How can you improve dramatically the application restart?<\/div><input type='hidden' name='question_id[]' id='qID_57' value='207714' \/><input type='hidden' id='answerType207714' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207714[]' id='answer-id-829654' class='answer   answerof-207714 ' value='829654'   \/><label for='answer-id-829654' id='answer-label-829654' class=' answer'><span>Mount a persistent volume for your RocksDB<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207714[]' id='answer-id-829655' class='answer   answerof-207714 ' value='829655'   \/><label for='answer-id-829655' id='answer-label-829655' class=' answer'><span>Increase the number of partitions in your inputs topic<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207714[]' id='answer-id-829656' class='answer   answerof-207714 ' value='829656'   \/><label for='answer-id-829656' id='answer-label-829656' class=' answer'><span>Reduce the Streams caching property<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207714[]' id='answer-id-829657' class='answer   answerof-207714 ' value='829657'   \/><label for='answer-id-829657' id='answer-label-829657' class=' answer'><span>Increase the number of Streams threads<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-58' style=';'><div id='questionWrap-58'  class='   watupro-question-id-207715'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>58. <\/span>What isn't a feature of the Confluent schema registry?<\/div><input type='hidden' name='question_id[]' id='qID_58' value='207715' \/><input type='hidden' id='answerType207715' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207715[]' id='answer-id-829658' class='answer   answerof-207715 ' value='829658'   \/><label for='answer-id-829658' id='answer-label-829658' class=' answer'><span>Store avro data<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207715[]' id='answer-id-829659' class='answer   answerof-207715 ' value='829659'   \/><label for='answer-id-829659' id='answer-label-829659' class=' answer'><span>Enforce compatibility rules<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207715[]' id='answer-id-829660' class='answer   answerof-207715 ' value='829660'   \/><label for='answer-id-829660' id='answer-label-829660' class=' answer'><span>Store schemas<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-59' style=';'><div id='questionWrap-59'  class='   watupro-question-id-207716'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>59. <\/span>A producer just sent a message to the leader broker for a topic partition. The producer used acks=1 and therefore the data has not yet been replicated to followers. <br \/>\r<br>Under which conditions will the consumer see the message?<\/div><input type='hidden' name='question_id[]' id='qID_59' value='207716' \/><input type='hidden' id='answerType207716' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207716[]' id='answer-id-829661' class='answer   answerof-207716 ' value='829661'   \/><label for='answer-id-829661' id='answer-label-829661' class=' answer'><span>Right away<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207716[]' id='answer-id-829662' class='answer   answerof-207716 ' value='829662'   \/><label for='answer-id-829662' id='answer-label-829662' class=' answer'><span>When the message has been fully replicated to all replicas<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207716[]' id='answer-id-829663' class='answer   answerof-207716 ' value='829663'   \/><label for='answer-id-829663' id='answer-label-829663' class=' answer'><span>Never, the produce request will fail<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207716[]' id='answer-id-829664' class='answer   answerof-207716 ' value='829664'   \/><label for='answer-id-829664' id='answer-label-829664' class=' answer'><span>When the high watermark has advanced<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div class='watu-question ' id='question-60' style=';'><div id='questionWrap-60'  class='   watupro-question-id-207717'>\n\t\t\t<div class='question-content'><div><span class='watupro_num'>60. <\/span>To continuously export data from Kafka into a target database, I should use<\/div><input type='hidden' name='question_id[]' id='qID_60' value='207717' \/><input type='hidden' id='answerType207717' value='radio'><!-- end question-content--><\/div><div class='question-choices watupro-choices-columns '><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207717[]' id='answer-id-829665' class='answer   answerof-207717 ' value='829665'   \/><label for='answer-id-829665' id='answer-label-829665' class=' answer'><span>Kafka Producer<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207717[]' id='answer-id-829666' class='answer   answerof-207717 ' value='829666'   \/><label for='answer-id-829666' id='answer-label-829666' class=' answer'><span>Kafka Streams<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207717[]' id='answer-id-829667' class='answer   answerof-207717 ' value='829667'   \/><label for='answer-id-829667' id='answer-label-829667' class=' answer'><span>Kafka Connect Sink<\/span><\/label><\/div><div class='watupro-question-choice  ' dir='auto' ><input type='radio' name='answer-207717[]' id='answer-id-829668' class='answer   answerof-207717 ' value='829668'   \/><label for='answer-id-829668' id='answer-label-829668' class=' answer'><span>Kafka Connect Source<\/span><\/label><\/div><!-- end question-choices--><\/div><!-- end questionWrap--><\/div><\/div><div style='display:none' id='question-61'>\n\t<div class='question-content'>\n\t\t<img loading=\"lazy\" decoding=\"async\" src=\"https:\/\/www.dumpsbase.com\/freedumps\/wp-content\/plugins\/watupro\/img\/loading.gif\" width=\"16\" height=\"16\" alt=\"Loading...\" title=\"Loading...\" \/>&nbsp;Loading...\t<\/div>\n<\/div>\n\n<br \/>\n\t\n\t\t\t<div class=\"watupro_buttons flex \" id=\"watuPROButtons6039\" >\n\t\t  <div id=\"prev-question\" style=\"display:none;\"><input type=\"button\" value=\"&lt; Previous\" onclick=\"WatuPRO.nextQuestion(event, 'previous');\"\/><\/div>\t\t  \t\t  \t\t   \n\t\t   \t  \t\t<div><input type=\"button\" name=\"action\" class=\"watupro-submit-button\" onclick=\"WatuPRO.submitResult(event)\" id=\"action-button\" value=\"View Results\"  \/>\n\t\t<\/div>\n\t\t<\/div>\n\t\t\n\t<input type=\"hidden\" name=\"quiz_id\" value=\"6039\" id=\"watuPROExamID\"\/>\n\t<input type=\"hidden\" name=\"start_time\" id=\"startTime\" value=\"2026-05-20 03:48:30\" \/>\n\t<input type=\"hidden\" name=\"start_timestamp\" id=\"startTimeStamp\" value=\"1779248910\" \/>\n\t<input type=\"hidden\" name=\"question_ids\" value=\"\" \/>\n\t<input type=\"hidden\" name=\"watupro_questions\" value=\"207658:829426,829427,829428,829429 | 207659:829430,829431,829432,829433 | 207660:829434,829435,829436,829437 | 207661:829438,829439 | 207662:829440,829441,829442,829443 | 207663:829444,829445,829446,829447 | 207664:829448,829449,829450 | 207665:829451,829452,829453,829454 | 207666:829455,829456,829457,829458 | 207667:829459,829460,829461,829462 | 207668:829463,829464,829465,829466 | 207669:829467,829468,829469,829470 | 207670:829471,829472,829473 | 207671:829474,829475,829476,829477 | 207672:829478,829479,829480,829481 | 207673:829482,829483,829484 | 207674:829485,829486,829487 | 207675:829488,829489,829490,829491 | 207676:829492,829493,829494,829495 | 207677:829496,829497,829498,829499 | 207678:829500,829501,829502,829503 | 207679:829504,829505,829506,829507 | 207680:829508,829509,829510,829511 | 207681:829512,829513,829514,829515 | 207682:829516,829517,829518,829519 | 207683:829520,829521,829522 | 207684:829523,829524,829525,829526 | 207685:829527,829528,829529,829530 | 207686:829531,829532,829533,829534 | 207687:829535,829536,829537,829538 | 207688:829539,829540,829541,829542,829543,829544 | 207689:829545,829546,829547,829548 | 207690:829549,829550,829551,829552,829553 | 207691:829554,829555,829556,829557 | 207692:829558,829559,829560 | 207693:829561,829562,829563 | 207694:829564,829565,829566,829567 | 207695:829568,829569,829570,829571,829572,829573 | 207696:829574,829575,829576,829577,829578,829579 | 207697:829580,829581,829582,829583 | 207698:829584,829585,829586,829587 | 207699:829588,829589,829590,829591 | 207700:829592,829593,829594,829595 | 207701:829596,829597,829598,829599,829600 | 207702:829601,829602,829603,829604 | 207703:829605,829606,829607,829608,829609,829610 | 207704:829611,829612,829613,829614 | 207705:829615,829616,829617,829618 | 207706:829619,829620,829621,829622 | 207707:829623,829624,829625,829626 | 207708:829627,829628,829629,829630,829631 | 207709:829632,829633,829634,829635 | 207710:829636,829637,829638 | 207711:829639,829640,829641,829642,829643,829644 | 207712:829645,829646,829647,829648,829649 | 207713:829650,829651,829652,829653 | 207714:829654,829655,829656,829657 | 207715:829658,829659,829660 | 207716:829661,829662,829663,829664 | 207717:829665,829666,829667,829668\" \/>\n\t<input type=\"hidden\" name=\"no_ajax\" value=\"0\">\t\t\t<\/form>\n\t<p>&nbsp;<\/p>\n<\/div>\n\n<script type=\"text\/javascript\">\n\/\/jQuery(document).ready(function(){\ndocument.addEventListener(\"DOMContentLoaded\", function(event) { \t\nvar question_ids = \"207658,207659,207660,207661,207662,207663,207664,207665,207666,207667,207668,207669,207670,207671,207672,207673,207674,207675,207676,207677,207678,207679,207680,207681,207682,207683,207684,207685,207686,207687,207688,207689,207690,207691,207692,207693,207694,207695,207696,207697,207698,207699,207700,207701,207702,207703,207704,207705,207706,207707,207708,207709,207710,207711,207712,207713,207714,207715,207716,207717\";\nWatuPROSettings[6039] = {};\nWatuPRO.qArr = question_ids.split(',');\nWatuPRO.exam_id = 6039;\t    \nWatuPRO.post_id = 35180;\nWatuPRO.store_progress = 0;\nWatuPRO.curCatPage = 1;\nWatuPRO.requiredIDs=\"0\".split(\",\");\nWatuPRO.hAppID = \"0.51409000 1779248910\";\nvar url = \"https:\/\/www.dumpsbase.com\/freedumps\/wp-content\/plugins\/watupro\/show_exam.php\";\nWatuPRO.examMode = 1;\nWatuPRO.siteURL=\"https:\/\/www.dumpsbase.com\/freedumps\/wp-admin\/admin-ajax.php\";\nWatuPRO.emailIsNotRequired = 0;\nWatuPROIntel.init(6039);\nWatuPRO.inCategoryPages=1;});    \t \n<\/script>\n","protected":false},"excerpt":{"rendered":"","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[13906,13907],"tags":[13901,13902,13903,13904,13905],"class_list":["post-35180","post","type-post","status-publish","format-standard","hentry","category-confluent","category-confluent-certified-developer","tag-ccdak","tag-ccdak-dumps","tag-ccdak-dumps-questions","tag-ccdak-exam-dumps","tag-ccdak-free-dumps"],"_links":{"self":[{"href":"https:\/\/www.dumpsbase.com\/freedumps\/wp-json\/wp\/v2\/posts\/35180","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.dumpsbase.com\/freedumps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.dumpsbase.com\/freedumps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.dumpsbase.com\/freedumps\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.dumpsbase.com\/freedumps\/wp-json\/wp\/v2\/comments?post=35180"}],"version-history":[{"count":1,"href":"https:\/\/www.dumpsbase.com\/freedumps\/wp-json\/wp\/v2\/posts\/35180\/revisions"}],"predecessor-version":[{"id":35183,"href":"https:\/\/www.dumpsbase.com\/freedumps\/wp-json\/wp\/v2\/posts\/35180\/revisions\/35183"}],"wp:attachment":[{"href":"https:\/\/www.dumpsbase.com\/freedumps\/wp-json\/wp\/v2\/media?parent=35180"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.dumpsbase.com\/freedumps\/wp-json\/wp\/v2\/categories?post=35180"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.dumpsbase.com\/freedumps\/wp-json\/wp\/v2\/tags?post=35180"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}