Kafka & Streaming questions and answers
Topics, consumer groups, stream processing and message queues. Page 10 of 20.
System Design practice on Codemia
Work through 120+ system design problems with detailed solutions, from rate limiters to multi-region storage.
Answers 541-600
- Explain AsyncEventingBasicConsumer behaviour without DispatchConsumersAsync = true
- Explain replication-offset-checkpoint AND recovery-point-offset in Kafka
- Exponential backoff with message order guarantee using spring-kafka
- Expose individual Kafka brokers on Kubernetes through an ELB on AWS
- Exposing Kafka as a public API
- External system queries during Kafka Stream processing
- Extract binary values from stream with low memory consumption
- Extract the time stamp from kafka messages in spark streaming?
- Extremely slow startup of a Spring Cloud Stream Kafka application when using enable.idempotence true
- Facing issue in Connecting Kafka 3.0 - org.apache.kafka.common.KafkaException Failed to load SSL keystore
- Failed to construct kafka producer with Springboot
- Failed to Create Cookie file RabbitMQ in Windows
- Failed to create topics,exception\norg.apache.kafka.common.errors.UnsupportedVersionException
- Failed to delete the state directory in IDE for Kafka Stream Application
- Failed to find data source Please deploy the application as per the deployment section of Structured Streaming + Kafka Integration Guide
- Failed to rebalance error in Kafka Streams with more than one topic partition
- Failed to resolve 'kafka9092' Name or service not known - docker / php-rdkafka
- Failed to start rabbitmq-management plugin on Windows
- Failing to write offset data to zookeeper in kafka-storm
- Fastest way to scan for bit pattern in a stream of bits
- Fault-tolerant queue-worker architecture in Kafka?
- Faust example of publishing to a kafka topic
- Filebeat 5.0 output to Kafka multiple topics
- Find broker id used in the Kafka cluster
- Find out Kafka version remotely
- Find partition(s) assigned to Kafka stream instance
- Find running median from a stream of integers
- Fixing under replicated partitions in kafka
- Flask + RabbitMQ + SocketIO - forwarding messages
- Flask API as real time kafka consumer
- Flink Kafka connector - commit offset without checkpointing
- flink kafka consumer groupId not working
- Flink Kafka EXACTLY_ONCE causing KafkaException ByteArraySerializer is not an instance of Serializer
- flink+Kafka getHostnamePort
- Fluentd vs Kafka
- Flume use case reading from HTTP and push to HDFS via Kafka
- For AvroProducer to Kafka, where are avro schema for key and value?
- For how long data is stored in kafka server?
- Force Confluent s3 sink to flush
- Force kafka consumer to poll partition with highest lag
- GCP dataproc - java.lang.NoClassDefFoundError org/apache/kafka/common/serialization/ByteArraySerializer
- get current config in kafka
- Get Kafka compressed message size
- Get last message from kafka consumer console script
- Get last modified date of a Kafka topic
- Get Latest Message for a Confluent Kafka Topic in Python
- Get number of messages in an Amazon SQS Queue
- Get the latest offsets in SSL Enabled Kafka via CMD
- Get topic from kafka message
- get topic from kafka message in spark
- Getting broker configuration via kafka-configs.sh
- Getting Broker may not be available error when spring boot container tries to connect kafka container
- Getting error while starting Kafka(3.4.0) with KRaft on windows machine
- Getting GroupNotEmptyException when trying to delete a consumer group in Kafka
- Getting java.lang.IllegalStateException Tried to lookup lag for unknown task 3_0 after upgrading Kafka Stream from 2.5.1 to 2.6.2
- Getting java.nio.file.AccessDeniedException on kafka on Windows
- Getting Multiple messages on spark-submit seeking to EARLIEST and Resetting offset for partition topic-partition
- Getting number of messages in a RabbitMQ queue
- Getting PreconditionFailed - inequivalent arg 'x-max-priority' for queue error when trying to set up priority queues with Celery+RabbitMQ
- Golang - RabbitMq channel/connection is not open
Course
Beginner
27 lessons
10 hours
System Design Fundamentals
Build a strong foundation in designing scalable, reliable distributed systems.
View the course