•Section
•How do I accurately get offsets for a certain timestamp using OffsetRequest
•What are the advantages of using Apache Kafka
•Can I add new Kafka brokers dynamically to a cluster
•What is Kafka Logs
•Which are the elements of Kafka
•Explain What Is Zookeeper In Kafka Can We Use Kafka Without Zookeeper
•How to replace a failed broker
•After bouncing a broker why do I see LeaderNotAvailable or NotLeaderForPartition
•How to reduce churns in ISR When does a broker leave the ISR
•Why Replication Is Required In Kafka
•Why do I see lots of Leader not local exceptions on the broker during shutdown
•How do I choose the number of partitions for a topic
•How many topics can I have
•Why partition leaders migrate themselves some times
•Why cant my consumersproducers connect to the brokers
•Why does controlled shutdown fail
•Why do I see error Should not set log end offset on partition in the broker
•How does Kafka depend on Zookeeper
•How do I get Kafka dependencies to work in Play framework
•How do I write unit tests using Kafka
•What is the difference between idempotent producer and transactional producer
•Why I still observe duplicated data in the final output topic with transactional
•How do I enable idempotent writes
•How do I enable transactional writes
•What are PIDs and sequence numbers and how are they related to transactionalid
•When do I need to configure a consumer in readcommitted mode
•Why are there many rebalances in my consumer log
•Why does my consumer never get any data
•Can a transaction span multiple partition segments
•How does exactlyonce work for compacted topics
•Why does my consumer get InvalidMessageSizeException
•Why some of the consumers in a consumer group never receive any message
•Should I choose multiple group ids or a single one for the consumers
•Can I predict the results of the consumer rebalance
•My consumer seems to have stopped why
•Why messages are delayed in my consumer
•How to improve the throughput of a remote consumer
•How can I rewind the offset in the consumer
•Can I manually manage my consumers offsets
•What is the relationship between fetchwaitmaxms and sockettimeoutms
•How do I get exactlyonce messaging from Kafka
•Why cant I specify the no of streams parallelism per topic map using wildcard
•How to consume large messages
•How do we migrate to committing offsets to Kafka rather than Zookeeper in
•How should I set metadatabrokerlist
•Why do I get QueueFullException in my producer when running in async mode
•I see data only produced on some of the brokers but not all why
•Why are my brokers not receiving producer sent messages
•Why is data not evenly distributed among partitions when a partitioning key
•Is it possible to delete a topic
•What does the Streams library do and how it affects my applications performance
•My application failed to start with the a rocksDB exception
•My applications memory usage keeps increasing when running until it hits an OOM
•Extracted timestamp value is negative which is not allowedWhat does this mean
•When does a record not contain a valid timestamp
•How to write a custom TimestampExtractor
•How to scale a Streams app ie increase number of input partitions
•What does exception Store someStoreName change log does not contain partition
•How can I access record metadata
•I get a locking exception similar to Caused by javaioIOException Failed
•Why do I get an IllegalStateException when accessing record metadata
•What is the role of offset in Kafka
•What is a consumer group
•What is the core API in Kafka
•Explain the functionality of producer API in Kafka
•Explain the functionality of Consumer API in Kafka
•Explain the functionality of Streams API in Kafka
•Explain the functionality of Connector API in Kafka
•Explain what is a topic
•What is the purpose of retention period in Kafka cluster
•Mention what is the maximum size of the message does Kafka server can receive
•Is it possible to get the message offset after producing
•Explain the concept of Leader and Follower
•If a Replica stays out of the ISR for a long time what does it signify
•How do you define a Partitioning Key
•In the Producer when does QueueFullException occur
•Can I add new brokers dynamically to a cluster
•How to solve kafkacommonInvalidMessageSizeExceptioninvalid message size error
•Is there a way to delete all data from topicdelete the topic before every run
•Scenario based Question
•How to reset Kafka offsets
•Explain the below properties in Kafka heartbeatintervalms sessiontimeoutms
•How to list all kafka topics
•Which directory does apache kafka store the data in broker nodes
•What is the basic difference between stream processing and traditional message
•Can we configured of Kafka to prioritize any topic or message
•We want to know which one is better Kafka or ActiveMQ
•Why is Kafka pullbased instead of pushbased
•How can I handle IOException when Kafka is down
•When and where to use Apache Kafka
•When does the Apache Kafka client throw a Batch Expired exception
•How to solve Kafka console consumer ERROR Offset commit failed on partition
•How to check if a topic was consumed by a consumer in Kafka
•