Kafka & Streaming questions and answers
Topics, consumer groups, stream processing and message queues. Page 20 of 20.
System Design practice on Codemia
Work through 120+ system design problems with detailed solutions, from rate limiters to multi-region storage.
Answers 1141-1200
- How to use Kafka with TLS peer verification turned off
- How to use kafkacat with message-hub
- How to use kafka.group.id and checkpoints in spark 3.0 structured streaming to continue to read from Kafka where it left off after restart?
- How to use multi-thread consumer in kafka 0.9.0?
- How to use priority in celery task.apply_async
- How to use Rabbit inside a gitlab-ci.yml file?
- How to use rabbitmqctl to connect to the rabbitmqserver in the docker container?
- How to use Spark Structured Streaming with Kafka Direct Stream?
- How to use the Kafka Connect JDBC to source PostgreSQL with multiple schemas that contain tables with the same name?
- How to use the rabbitmq docker compose yml file to build docker image?
- How to use two Kerberos keytabs (for Kafka and Hadoop HDFS) from a Flink job on a Flink standalone cluster?
- How to view and set offsets.retention.minutes using kafka-configs
- how to view kafka headers
- How to write a Dataset to Kafka topic?
- How to write Kafka consumers - single threaded vs multi threaded
- How to write Kafka consumers - single threaded vs multi threaded
- How to write Kafka Producer in Scala
- How to write spark streaming DF to Kafka topic
- How to write streaming dataset to Kafka?
- How to write to Kafka from Python logging module?
- How ZooKeeper guarantees Single System Image?
- I am trying to run kafka on windoes 10 but erros shows Error Could not find or load main class Files\kafka\libs\activation-1.1.1.jar;C\Program
- I am using Python3 and I want to use RabbitMQ
- I cannot start rabbitmq on my mac
- I can't run Kafka on windows
- I can't run zookeeper
- I need to create a kafka image with topics already created
- I need to mock a RabbitMQ in my unit Test
- IBM MQ Multi-Instance Queues
- Ideal value for Kafka Connect Distributed tasks.max configuration setting?
- Identify and find specific message in Kafka topic
- If exactly-once semantics are impossible, what theoretical constraint is Kafka relaxing?
- if i set value of commit.interval.ms = in kafka stream, Whether it will be able to commit offset?
- If I use compression with Avro does it make sense to enable Topic Compression in Kafka?
- If rabbitmq can''t be used as a locking service, then what can?
- If you have less consumers than partitions, what happens?
- IllegalArgumentException /tmp/zookeeper/myid file is missing
- Impact of reducing max.poll.records in Kafka Consumer configuration
- Implement Kafka Streams Processor in .Net?
- Implement Reactive Kafka Listener in Spring Boot application
- Implementing a kafka connect custom partitioner
- Implementing fault tolerance in distributed message queues
- Implementing non-blocking retry with backoff with spring-amqp and rabbitmq
- Implementing sagas with Kafka
- Import broker definitions into Dockerized RabbitMQ
- ImportError cannot import name 'Celery' from 'celery
- Improving performance of Kafka Producer
- In-memory vs persistent state stores in Kafka Streams?
- In a Reactive scenario what should be better Reactor Kafka or Kafka Listener
- In Celery, how can I keep long-delayed tasks from blocking newer ones?
- In Kafka Connect, how to connect with multiple kafka clusters?
- In Kafka HA, why minimum number of brokers required are 3 and not 2
- In Kafka how to get the exact offset according producing time
- in Kafka, how to make consumers consume from local partition?
- In Kafka is each message replicated across all partitions of a topic?
- In kafka, When producing message with transactional, Consumer offset doubled up
- In Pika or RabbitMQ, How do I check if any consumers are currently consuming?
- In RabbitMQ which is more expensive, multiple queues per exchange, or multiple exchanges and less queues per each?
- In Spring Kafka, do I need to add the @EnableKafka annotation to my application?
- In Spring Kafka, do I need to add the EnableKafka annotation to my application?
Course
Beginner
27 lessons
10 hours
System Design Fundamentals
Build a strong foundation in designing scalable, reliable distributed systems.
View the course