Kafka & Streaming questions and answers
Topics, consumer groups, stream processing and message queues. Page 15 of 20.
System Design practice on Codemia
Work through 120+ system design problems with detailed solutions, from rate limiters to multi-region storage.
Answers 841-900
- How to create a delayed queue in RabbitMQ?
- How to create a kafka consumer group in Golang?
- How to Create a Kafka Consumer Record from a String to build Junit test case
- How to create a Kafka Topic using Confluent.Kafka .Net Client
- How to create a list of topics in Apache Kafka using single command
- How to create a new consumer group in kafka
- How to create a queue in RabbitMQ upon startup
- How to create a Topic in Kafka through Java
- How to create Custom serializer in kafka?
- How to create dynamic queues in rabbit mq using spring boot?
- How to create InputDStream with offsets in PySpark (using KafkaUtils.createDirectStream)?
- How to create kafka compacted topic
- How to create kafka topic with partitions in nodejs?
- How to create Kafka user and consumer group for ACLs in a running cluster?
- How to create KSQL Stream with large number of JSON fields from topic in kafka?
- How to create multiple instances of KafkaReceiver in Spring Reactor Kafka
- How to create topic in Kafka with Python-kafka admin client?
- How to create topics in apache kafka?
- How to create unit test with kafka embedded in the spring cloud stream
- How to create ZeroMQ socket suitable both for sending and consuming?
- How to deal with Kafka warning Error while loading kafka-streams-version.properties java.lang.NullPointerException inStream parameter is null
- How to decide Kafka Cluster size
- How to decide the concurrency to be set in spring kafka?
- How to declaratively manage Kafka topics?
- How to decode/deserialize Avro with Python from Kafka
- How to decrease number partitions Kafka topic?
- How to delete a queue in rabbit mq
- How to delete kafka consumer group (created via new consumer api)?
- how to delete kafka message after reading
- How to delete Kafka topic using Kafka REST Proxy?
- How to delete multiple topics in Apache Kafka
- How to delete the consumer offset of a group for one specific topic
- How to deploy Kafka Stream applications on Kubernetes?
- How to deploy Kafka Streaming Application on Kafka Cluster
- How to deserialize records from Kafka using Structured Streaming in Java?
- How to design task distribution with ZooKeeper
- How to detect dead RabbitMQ connection?
- How to detect duplicate messages in a kafka topic?
- How to determine a Kafka consumer's offset
- How to determine API version of Kafka?
- How to disable all Kafka related auto configuration from yaml/properties file in spring-boot-2 without removing dependencies?
- How to disable JSON schema in Kafka Source Connector (e.g. Debezium)
- How to disable RabbitMQ default tcp listening port - 5672
- How to do content filtering with Apache Kafka?
- How to do error handling with EasyNetQ / RabbitMQ
- How to dynamically add consumers in consumer group kafka
- How to Dynamodb send message to SQS
- How to efficiently compute average on the fly moving average?
- How to efficiently create Kafka topics with testcontainers?
- how to efficiently merge int ranges in a stream?
- how to efficiently move data from Kafka to an Impala table?
- How to enable GC logging for Apache Kafka brokers, while preventing log file overwrites and capping disk space usage
- How to enable Kafka logging with log4j
- How to enable remote JMX on Kafka brokers (for JmxTool)?
- How to enable stats in RabbitMQ management UI
- How to encode/decode Kafka messages using Avro binary encoder?
- how to enforce schema validation in kafka
- How to ensure task execution order per user using Celery, RabbitMQ and Django?
- How to export data from Kafka to Prometheus?
- How to expose a headless Kafka service for a StatefulSet externally in Kubernetes
Course
Beginner
27 lessons
10 hours
System Design Fundamentals
Build a strong foundation in designing scalable, reliable distributed systems.
View the course