Kafka & Streaming questions and answers
Topics, consumer groups, stream processing and message queues. Page 9 of 20.
System Design practice on Codemia
Work through 120+ system design problems with detailed solutions, from rate limiters to multi-region storage.
Answers 481-540
- Don't print the kafka-console-consumer warnings
- Dropping container with RabbitMQ in Docker
- DStream filtering and offset management in Spark Streaming Kafka
- During rolling upgrade/restart, how to detect when a kafka broker is done?
- Dynamic addition of queues to a rabbit listener at runtime
- Dynamic periodic tasks - alternatives to Celery beat
- Dynamic queue creation with RabbitMQ
- Dynamic Topic Name / Quarkus SmallRye Reactive Messaging Kafka
- Dynamically changing the instanceindex with spring cloud stream kafka
- Dynamically connecting a Kafka input stream to multiple output streams
- Dynamically update topics list for spark kafka consumer
- DynamoDB Stream in-ordering processing
- EasyNetQ fails to publish to RabbitMQ - PersistentChannel timed out
- econnrefused 127.0.0.15672 Rabbit-mq with docker compose
- Elasticsearch vs Kafka Putting intelligence in producers
- Embedded Kafka for testing without spring
- Embedded Kafka integration test - consumer never completes
- Embedded Kafka Spring test executes before embedded Kafka is ready
- Embedded Kafka tests randomly failing
- Emulating Amazon SQS during development
- Enable SSL for Kafka Clients
- End-of-window outer join with KafkaStreams
- End-to-end Exactly-once processing in Apache Flink
- Enforce Unique consumer group id in Kafka
- Ensuring consistency with Kafka Schema and OpenAPI specification
- Ensuring that all messages have been read from Kafka topic using REST Proxy
- Equivalent for Kafka / AWS Kinesis Stream on Google Cloud Platform
- Error connecting to kafka server via IDE in WSL2
- Error connecting to local Bitnami Docker Kafka from Spring Boot application
- Error Could not find or load main class config.zookeeper.properties
- Error creating Kafka topic - replication factor larger than available brokers
- Error in Zookeeper Unreasonable length = 308375649 when creating topic in Kafka
- error on creating spring Embedded kafka instance
- ERROR org.apache.kafka.common.utils.KafkaThread - Uncaught exception in thread 'kafka-producer-network-thread
- Error org.springframework.kafka.KafkaException Seek to current after exception;
- error package org.apache.kafka.clients.producer does not
- Error reading field 'topic_metadata' in Kafka
- Error reading field 'topics' java.nio.BufferUnderflowException in Kafka
- Error sending fetch request (sessionId=1175648978, epoch=189) to node 53 org.apache.kafka.common.errors.DisconnectException
- Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 1001 org.apache.kafka.common.errors.DisconnectException
- Error to serialize message when sending to kafka topic
- Error unknown delivery tag occurs when i try ack messages to RabbitMQ using pika (python)
- Error when Spark 2.2.0 standalone mode write Dataframe to local single-node Kafka
- Error while creating topic in kafka
- Error while executing Kafka on port 2181 - topic command Timed out waiting for a node assignment. OS Win 10
- error while starting kafka broker
- Event-Time merge of two Kafka topics using Kafka Streams DSL
- Event driven microservices with message brokers (e.g. Kafka) vs reactive programming (RxJava, Project Reactor) plus improved protocols (RSocket)
- Event sourcing with Kafka streams
- Event vs Topic Apache Kafka
- Eventsourcing in Apache Kafka
- Examples of Django and Celery Periodic Tasks
- Examples of Kafka Rest
- Exception during topic deletion when Kafka is hosted in Docker in Windows
- Exception running kafka-console-producer.sh (0.8.1.1)
- Exception when processing data during Kafka stream process
- Exception while accessing KafkaOffset from RDD
- Exceptions in rabbitmq with spring boot
- Excessive console messages from Kafka Producer
- Expected behavior for AWS Kinesis ShardIteratorType TRIM_HORIZON
Course
Beginner
27 lessons
10 hours
System Design Fundamentals
Build a strong foundation in designing scalable, reliable distributed systems.
View the course