Kafka & Streaming questions and answers
Topics, consumer groups, stream processing and message queues. Page 4 of 20.
System Design practice on Codemia
Work through 120+ system design problems with detailed solutions, from rate limiters to multi-region storage.
Answers 181-240
- Can I dispatch messages with a custom algorithm instead of round robin using RabbitMQ?
- Can I dispatch messages with a custom algorithm instead of round robin using RabbitMQ?
- Can I get producer client id in kafka consumer?
- Can I have 100s of thousands of topics in a Kafka Cluster?
- Can I ignore org.apache.kafka.common.errors.NotLeaderForPartitionExceptions?
- Can I iterate through queues using the RabbitMQ .NET Client?
- can I limit consumption of kafka-node consumer?
- Can I retrieve the latest available offset for a Kafka partition without retrieving all the messages?
- Can I set Kafka Stream consumer group.id?
- Can I specify RabbitMQ credentials in node.js?
- can i traverse the items in a KTable from an external method
- Can I use kafka over Internet?
- Can I use Kafka queue in my Rest WEBSERVICE
- Can I use my Service Mesh for Event-Driven Messaging?
- Can I use RabbitMQ to distribute large files to multiple machines?
- Can I use Spring WebFlux to implement REST services which get data through Kafka request/response topics?
- Can I write to an AWS MSK Kafka cluster from a Lambda function?
- Can Kafka be provided with custom LoginModule to support LDAP?
- Can Kafka Connect guarantee the write order when RetriableException occurs?
- Can Kafka Streams be configured to wait for KTable to load?
- Can Kafka streams deal with joining streams efficiently?
- Can single consumer read from multiple partitions of a kafka topic?
- Can single Kafka producer produce messages to multiple topics and how?
- Can talk to Zookeeper but not to the message brokers
- Can the same Zookeeper instance be used by number of services?
- can vert.x event bus replace the need for Kafka?
- Can we disable log4j logs only for kafka
- Can we have retention period of zero in Kafka broker?
- Can we have strong routing capability with Apache Kafka similar to RabbitMq?
- Can we update/Upsert a record in mongodb? data source is kafka
- Can we use any other database like MariaDB or MongoDB for Storing states in Kafka Streams instead of Rocks DB, is there any way to configure it?
- Can we use multiple kafka template in spring boot?
- Can we use RabbitMQ and Mediatr together using masstransit?
- Can you scale DOWN the number of Kafka brokers in an Amazon MSK cluster?
- Can you split a stream into two streams?
- Can you use Consul instead of Zookeeper for Kafka
- Cannot Connect from Kafkacat running in docker to Kafka broker running locally on windows machine
- Cannot connect to Kafka from Flask in a dockerized environement
- Cannot connect to remote zookeeper
- Cannot connect to single-node Kafka server through Docker
- Cannot enable rabbitmq-management plugin on Windows
- Cannot start Kafka because of log file used by another process?
- Can't access RabbitMQ web management interface after fresh install
- can't connect to kafka server
- Can't figure out setting for inter.broker.listener.name in Kafka with SSL
- Can't see timestamps in Apache Kafka 0.10.0.0. RC4
- Can't set Kafka retention policy to both compact and delete
- Can't start Kafka Connect with MongoDb plugin with Apache Kafka
- can't start rabbitmq-server after installation
- Can't start zookeeper
- Capture Heroku SIGTERM in Celery workers to shutdown worker gracefully
- Cassandra + kafka for event sourcing
- Celery - Asynchronous Task Chaining
- celery - call function on task done
- Celery - Can a message in RabbitMQ be consumed by two or more workers at the same time?
- Celery - errno 111 connection refused
- Celery & RabbitMQ running as docker containers Received unregistered task of type '...
- Celery and Flower nothing in broker tab
- Celery and RabbitMQ - queue priority vs. consumer priority vs. task priority
- Celery Beat Limit to single task instance at a time
Course
Beginner
27 lessons
10 hours
System Design Fundamentals
Build a strong foundation in designing scalable, reliable distributed systems.
View the course