Kafka & Streaming questions and answers
Topics, consumer groups, stream processing and message queues. Page 5 of 20.
System Design practice on Codemia
Work through 120+ system design problems with detailed solutions, from rate limiters to multi-region storage.
Answers 241-300
- Celery broadcast vs RabbitMQ fanout
- Celery chain not working with batches
- Celery connection drop with AWS ELB and RabbitMQ
- Celery (Django) Rate limiting
- Celery does not release memory
- Celery dynamic queue creation and routing
- Celery Error in connecting to RabbitMQ Server
- Celery First Steps - timeout error on result.get()
- Celery how can I route a failed task to a dead-letter queue
- Celery how to limit number of tasks in queue and stop feeding when full?
- Celery in Docker container ERROR/MainProcess consumer Cannot connect to redis
- Celery inspect function is hanging, how to troubleshoot?
- Celery node fail, on pidbox already using on restart
- Celery parallel distributed task with multiprocessing
- Celery rpc vs amqp result backend
- Celery task schedule (Celery, Django and RabbitMQ)
- Celery tasks disappear
- Celery tasks received but not executing
- celery tasks, workers and queues organization
- Celery upgrade (3.1->4.1) - Connection reset by peer
- Celery When should you choose Redis as a message broker over RabbitMQ?
- Celery with Amazon SQS
- Celery with rabbitmq creates results multiple queues
- Celery WorkerLostError Worker exited prematurely signal 6 SIGABRT
- celeryev Queue in RabbitMQ Becomes Very Large
- Change-data-capture from Postgres SQL to kafka topics using standalone mode Kafka-connect
- Change Default 'home' Path in Erlang to Resolve RabbitMQ Start Up Error
- Changing hostname breaks Rabbitmq when running on Kubernetes
- Changing hostname breaks Rabbitmq when running on Kubernetes
- Changing the headers and body of a RabbitMQ message when retrying it?
- Check all the lags in Kafka
- Check for the existence of a Kafka topic programatically in Java
- Check If System Is Connected To Kafka
- Check RabbitMQ queue size from client
- Check whether a Kafka topic exists in Python
- Checking the existence of topic in kafka before creating in Java
- Choosing the right cleanup policy in Kafka configuration
- Circuit breaker with kafka consumer
- Clarification of use-cases for Hadoop versus RabbitMQ+Celery
- ClassNotFoundException org.apache.flink.streaming.api.checkpoint.CheckpointNotifier while consuming a kafka topic
- ClassNotFoundException with Kafka consumer
- Clear a Kafka consumer group with stuck members
- Clear kafka topics for unit testing
- Clickhouse cannot alter columns throws DBException Metadata on replica is not up to date with common metadata in Zookeeper
- ClickHouse Kafka Performance
- Client network socket disconnected before secure TLS connection was established. How can I connect to a kafka cluster using Kafka JS in Node js?
- close Kafka via TERMINAL
- Combine results from batch RDD with streaming RDD in Apache Spark
- Commit Asynchronously a message just after reading from topic
- common.KafkaException com.fasterxml.jackson.databind.ser.std.StringSerializer is not an instance of org.apache.kafka.common.serialization.Serializer
- Communication among microservices Apache Kafka vs Hazelcast's Topic
- Comparing kafka-node and node-rdkafka
- Comparison between RabbitMQ and MSMQ
- Concurrency of Kafka streams topology with multiple output topics
- Concurrent writes for event sourcing on top of Kafka
- Conditions in which Kafka Consumer (Group) triggers a rebalance
- Configure kafka-net to stop sending latest messages
- Configure Kafka to expose JMX only on 127.0.0.1
- Configuring ACL for kafka topic
- Configuring ConnectionFactory for RabbitMQ in Spring Boot AMQP
Course
Beginner
27 lessons
10 hours
System Design Fundamentals
Build a strong foundation in designing scalable, reliable distributed systems.
View the course