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 dat a. How can you improve dramatically the application restart?

• A.Mount a persistent volume for your RocksDB
• B.Increase the number of partitions in your inputs topic
• C.Reduce the Streams caching property
• D.Increase the number of Streams threads

Comment: *

Name: *

Email: *

Verification: *

What is the risk of increasing max.in.flight.requests.per.connection while also enabling retries in a producer?

• A.At least once delivery is not guaranteed
• B.Message order not preserved
• C.Reduce throughput
• D.Less resilient

Comment: *

Name: *

Email: *

Verification: *

is KSQL ANSI SQL compliant?

• A.Yes
• B.No

Comment: *

Name: *

Email: *

Verification: *

An application is writing AVRO messages using Schema Registry to topic t1. During this process, the Schema Registry becomes unavailable for a few seconds.
What is the expected impact to the application?

• A.Since messages are cached by the producer, the application will only get an error if the producer is sending the batch at that time.
• B.Since the broker will eventually replicate the message Schema, there will not be an error.
• C.The application may not have any impact, unless it is writing messages with a new Schema Definition.
• D.All messages within that time will receive an error.

Comment: *

Name: *

Email: *

Verification: *

How do you read a table or stream from the beginning of a topic?

• A.id as paymentId
  FROM orders o
  INNER JOIN payments p WITHIN 1 HOURS ON p.id = o.id
  INNER JOIN shipments s WITHIN 2 HOURS ON s.id
  = o.id;
• B.id as shipmentId,
• C.id as orderId
• D.SET 'auto.offset.reset' = 'latest';
  SELECT STRUCT(f1 := v1, f2 := v2) FROM s1 EMIT CHANGES;
• E.CREATE STREAM shipped_orders AS
  SELECT
• F.itemId as itemId,
• G.SELECT STRUCT(f1 := v1, f2 := v2) FROM s1 EMIT CHANGES;
• H.SET 'auto.offset.reset' = 'earliest';
  SELECT STRUCT(f1 := v1, f2 := v2) FROM s1 EMIT CHANGES;

Comment: *

Name: *

Email: *

Verification: *