Kafka & Streaming questions and answers
Topics, consumer groups, stream processing and message queues. Page 8 of 20.
System Design practice on Codemia
Work through 120+ system design problems with detailed solutions, from rate limiters to multi-region storage.
Answers 421-480
- Distribute messages equally into partitions in kafka
- Distributed architecture with MassTransit, RabbitMQ and SignalR
- Distributed Indexing using Zookeeper and Redis
- Distributed Kafka Connect topic configuration
- Distributed Transaction vs Message Queue
- Django-celery and RabbitMQ not executing tasks
- Django - Executing a task through celery from a model
- Django and celery on different servers and celery being able to send a callback to django once a task gets completed
- Django Celery Beat admin updating Cron Schedule Periodic task not taking effect
- Django Celery Execute only one instance of a long-running process
- Django, Celery, Redis, RabbitMQ Chained Tasks for Fanout-On-Writes
- Django celery tasks in separate server
- Django Celery tutorial not returning results
- Django, RabbitMQ, & Celery - why does Celery run old versions of my tasks after I update my Django code in development?
- Do we have a option to get data in KSQL streams from specific time-period/Timestamp
- Do we need to connect everytime we producer Kafka message?
- Do you need multiple zookeeper instances to run a multiple-broker kafka?
- docker-compose kafka wait for zookeeper and schema-registry wait for kafka
- Docker-ized Consul, Zookeeper and Kafka in Amazon-ECS
- Docker build fails due to kafka undefined error
- Docker (Compose) client connects to Kafka too early
- Docker compose create kafka topics
- Docker Kafka client to Docker Kafka broker connection refused
- Docker Kafka w/ Python consumer
- docker rabbitmq how to expose port and reuse container with a docker file
- Docker rabbitmq image fails with [error] Too short cookie string
- Docker RabbitMQ persistency
- Docker/Kubernetes Gunicorn/Celery - Multiple Workers vs Replicas?
- Does a Kafka Consumer default batch size?
- Does Apache Kafka 0.9.x not generate csv for metrics ByteInPerSec and ByteOutPerSec
- Does Apache Kafka provide an asynchronous subscription callback API?
- Does commitOffsets on high-level consumer block?
- Does Debezium provide delivery and ordering guarantees?
- Does enabling Idempotence on a Kafka producer decrease throughput
- Does errors.deadletterqueue.topic.name work for source connector
- Does gRPC vs NATS or Kafka make any sense?
- Does Kafka guarantee message ordering within a single partition with ANY config param values?
- does kafka have a async request/response java api?
- Does Kafka have a batch consumer?
- Does Kafka have a visibility timeout?
- Does kafka have any default web UI
- Does Kafka python API support stream processing?
- Does Kafka rebalancing algorithm balance across topics?
- Does Kafka Streams aggregation stage serialize and deserialize each single element?
- Does Kafka support ELB in front of broker cluster?
- Does Kafka support java 10 or java 11?
- Does Kafka support priority for topic or message?
- Does Kafka support request response messaging
- Does Kafka support secure communication?
- Does Kafka supports XA transactions?
- Does Kafka's message include timestamp by default?
- Does min insync replicas property effects consumers in kafka
- Does min.insync.replica configuration affect Kafka producer throughput?
- Does RabbitMQ call the callback function for a consumer when it has some message for it?
- Does RabbitMq do round-robin from the exchange to the queues
- Does RabbitMQ or Kafka fit for real time dashboard applications?
- Does rabbitmq support binding a single queue to multi exchanges?
- Does Spark Structured Streaming maintain the order of Kafka messages?
- Does the content type header in RabbitMQ have any special meaning?
- Does the number of consumer groups impact Kafka performance

Course
Beginner
27 lessons
10 hours
System Design Fundamentals
Build a strong foundation in designing scalable, reliable distributed systems.
View the course