How much should be the heap size of a broker in a production setup on a machine with 256 GB of RAM, in PLAINTEXT mode?
In Kafka, a small heap size is needed, while the rest of the RAM goes automatically to the page cache (managed by the OS). The heap size goes slightly up if you need to enable SSL
A Zookeeper configuration has tickTime of 2000, initLimit of 20 and syncLimit of 5. What's the timeout value for followers to connect to Zookeeper?
tick time is 2000 ms, and initLimit is the config taken into account when establishing a connection to Zookeeper, so the answer is 2000 * 20 = 40000 ms = 40s
Your streams application is reading from an input topic that has 5 partitions. You run 5 instances of your application, each with num.streams.threads set to 5. How many stream tasks will be created and how many will be active?
One partition is assigned a thread, so only 5 will be active, and 25 threads (i.e. tasks) will be created
Where are KSQL-related data and metadata stored?
metadata is stored in and built from the KSQL command topic. Each KSQL server has its own in-memory version of the metastore.
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. Where will the consumer read from?
Latest means that data retrievals will start from where the offsets currently end
Mira
12 days agoBrock
23 days agoRolande
27 days agoCarey
1 months agoVirgina
2 months agoAllene
2 months agoBroderick
2 months agoGary
2 months agoShelton
2 months agoMisty
3 months agoMabel
3 months agoDorian
4 months agoMicheal
5 months agoLinsey
5 months ago