Kafka & Streaming questions and answers
Topics, consumer groups, stream processing and message queues. Page 7 of 20.
System Design practice on Codemia
Work through 120+ system design problems with detailed solutions, from rate limiters to multi-region storage.
Answers 361-420
- Creating a topic for Apache Kafka 0.9 Using Java
- CSV Connector For Kafka
- Curl to get Rabbitmq queue size
- Current offset behavior when set by kafka-consumer-groups to earliest?
- Custom Error Queue Name when using EasyNetQ for RabbitMQ?
- Custom serialization in Kafka using CSharp
- Data still remains in Kafka topic even after retention time/size
- Dead letter queue (DLQ) for Kafka with spring-kafka
- Dealing with dead letters in RabbitMQ
- Dealing with Kafka Producer connection loss
- Debezium-contains no connector type
- Debezium Unable to setup watcher on Kafka-Connect Docker container. Error while fetching metadata with correlation id 2 ... LEADER_NOT_AVAILABLE
- Debounce kafka events
- Debugging celery WorkerLostError with exitcode zero (Django 1.5.5 + celery 3.1.8 + RabbitMQ 3.1.3 on Heroku)
- Debugging process for Kafka SSL security
- Default serializer for kafka 0.8.2.0
- Delay in Consumer consuming messages in Apache Kafka
- Delayed message consumption in Kafka
- Delayed message in RabbitMQ
- Delayed Queue implementation in Storm – Kafka, Cassandra, Redis or Beanstalk?
- Delaying Kafka Streams consuming
- Delete all the queues from RabbitMQ?
- Delete Messages from a Topic in Apache Kafka
- delete Task / PeriodicTask in celery
- Delete unused kafka consumer group
- delete.retention.ms at the time of creating topic in kafka on 0.8.1 version
- Deleting all pending tasks in celery?
- Deleting queues in RabbitMQ
- Demultiplexing messages from a queue to process in parallel streams using amqp?
- Deserialize Avro messages into specific datum using KafkaAvroDecoder
- Deserializing a kafka message without schema registry
- Deserializing different JSON payload from same Kafka topic with Spring Kafka
- Desigining Kafka Topics - Many Topics vs One Big Topic
- Designing a Distributed Cache with a Globally Aware Eviction Policy using Caffeine, InfintiSpan & RabbitMQ
- Determine the Kafka-Client compatibility with kafka-broker
- Difference Avro Vs Cloudevent Vs AsyncAPI | Best fit for Schema evolution and naming convention in kafka
- Difference between Apache Samza and Apache Kafka Streams (focus on parallelism and communication)
- Difference between event queue and message queue
- Difference between Faust vs Kafka-python
- Difference between group id, Client id and id in KafkaListener Spring Boot
- Difference between heartbeat.interval.ms and session.timeout.ms in Kafka consumer config
- Difference between idempotence and exactly-once in Kafka Stream
- Difference between Kafka and ActiveMQ
- Difference between kafka and nifi
- Difference between Kafka async and Kafka sync acks=0?
- Difference between KTable and local store
- Difference between 'metric.reporters' and 'kafka.metrics.reporters' properties in Kafka
- Difference between request.timeout.ms and timeout.ms properties of Kafka producer
- Difference between retention configuration offsets.retention.minutes and log.retention.minutes
- DIfference between Spring Kafka and Spring Integration Kafka
- Difference between Spring Kafka lib and native Kafka Java API
- Difference between stream processing and message processing
- Difference between Zookeeper and a managed replicated database service
- Difference in kafka 0.8 with kafka 0.10
- Different between KafkaProducer.close() and KafkaProducer.flush()
- Differentiate celery, kombu, PyAMQP and RabbitMQ/ironMQ
- Direct Kafka Stream with PySpark (Apache Spark 1.6)
- Directory name is invalid. etc. with rabbitmq-plugins on Windows
- Disable mirrormaker2 offset-sync topics on source kafka cluster
- Disabling Kafka Listeners for a particular Spring Boot test
Course
Beginner
27 lessons
10 hours
System Design Fundamentals
Build a strong foundation in designing scalable, reliable distributed systems.
View the course