Kafka & Streaming questions and answers
Topics, consumer groups, stream processing and message queues. Page 14 of 20.
System Design practice on Codemia
Work through 120+ system design problems with detailed solutions, from rate limiters to multi-region storage.
Answers 781-840
- How to add plugin to RabbitMQ docker image?
- How to alter the TTL for a particular topic in Kafka
- How to always consume from latest offset in kafka-streams
- How to apply an SMT to a single topic in Kafka connect?
- How to ask RabbitMQ to retry when business Exception occurs in Spring Asynchronous MessageListener use case
- How to assign client-id to a particular Kafka Producer or Topic?
- How to authenticate/authorize a consumer in Kafka for a topic before it consumes the message
- How to auto-scale Kubernetes Pods based on number of tasks in celery task queue?
- How to automate Kafka Testing
- How to automatically start Kafka upon system startup in Ubuntu?
- How to batch process incoming tasks into 10 task in celery?
- How to build efficient Kafka broker healthcheck?
- How to calculate or approximate the median of a list without storing the list
- How to catch deserialization error in Kafka-Spring?
- How to change default port(15672) of RabbitMQ Management plugin?
- how to change Kafka broker list ip
- How to change RabbitMQ Heartbeat without restart
- How to change the name of the topic generated by Kafka Connect Source Connector
- How to check consumer offsets when the offset store is Kafka?
- How to check if a topic was consumed by a consumer in Kafka
- How to check if Kafka Consumer is ready
- How to check Kafka server status or details?
- How to check the actual number of incremental fetch session cache slots used in Kafka cluster?
- How to check the existence of Kafka topic in Nodejs
- How to check which partition is a key assign to in kafka?
- How to check which zookeeper instance is the leader within an ensemble
- How to choose Kafka transactional.id in a Kubernetes (Producer side only transaction) set up
- How to choose the no of partitions for a kafka topic?
- How to close kafka consumer once all messages are consumed?
- how to compress data in producers when using spring kafka
- How to configure Celery to run as systemd service with a Django application served by Gunicorn?
- How to configure Confluent Platform Kafka connect logs?
- How to configure docker-compose.yml for Kafka local development?
- How to configure kafka consumer with sasl mechanism PLAIN and with security protocol SASL_SSL in java?
- How to configure Kafka to behave like a FiFo queue?
- How to configure kafka topic retention policy during creation with Spring?
- How to configure logging for Kafka producers?
- How to configure RabbitMQ connection with spring-rabbit?
- How to configure RabbitMQ connection with spring-rabbit?
- How to configure RabbitMQ using Active/Passive High Availability architecture
- How to configure the time it takes for a kafka cluster to re-elect partition leaders after stopping and restarting a broker?
- How to connect Apache Kafka with Amazon S3?
- How to connect kafka topic with web endpoint using Faust Python package?
- How to connect Kafka with Elasticsearch?
- How to connect local kafka in docker container?
- How to connect pika to rabbitMQ remote server? (python, pika)
- How to connect to MSK with SASL/SCRAM using Java?
- How to connect to multiple clusters in a single Kafka Streams application?
- how to connect to rabbitmq using javascript without nodejs
- How to consume from Kafka Spring Cloud Stream by default and also consume a Kafka message generated by the confluent API?
- How to Consume from specific TopicPartitionOffset with Confluent.Kafka in .Net
- How to consume just one message from rabbit mq on nodejs
- How to consume messages between two timestamps using Kafka Console Consumer
- How to consume messages in last N days using confluent-kafka-python?
- How to consume RabbitMQ messages via pika for some limited time?
- How to control user access for Kafka Topics?
- How to convert bytes from Kafka to their original object?
- How to copy a topic from a kafka cluster to another kafka cluster?
- How to copy messages to another queue on RabbitMQ?
- How to count number of records (message) in the topic using kafka-python

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