Kafka & Streaming questions and answers
Topics, consumer groups, stream processing and message queues. Page 19 of 20.
System Design practice on Codemia
Work through 120+ system design problems with detailed solutions, from rate limiters to multi-region storage.
Answers 1081-1140
- How to set cleanup.policy 'delete' AND 'compact' for a Kafka topic?
- How to set consumer.id for new Kafka consumer
- How to set group name when consuming messages in kafka using command line?
- How to set group.id for consumer group in kafka data source in Structured Streaming?
- How to set kafka-connect connector and task's JVM heap size?
- how to set kafka consumer concurrency using spring boot
- How to set Kafka parameters from a properties file?
- How to set offset committed by the consumer group using Spark's Direct Stream for Kafka?
- How to set offset in kafkalistener
- How to set optimal config values - trigger time, maxOffsetsPerTrigger - for Spark Structured Streaming while reading messages from Kafka?
- How to set per-message expiration (TTL) in Celery?
- How to set Principal in Kafka console producer/consumer?
- How to set timeout detection on a RabbitMQ server?
- How to set timeout for onFailure event (Spring, Kafka)?
- How to set up autoscaling RabbitMQ Cluster AWS
- how to setup basic rabbitmq on kubernetes
- How to setup kafka transactional producer
- How to setup multiple topics in a RabbitMQ Java config class using Spring Framework?
- How to shift back the offset of a topic within a stable Kafka consumer group?
- How to show continuous real time updates like facebook ticker, meetup.com home page does?
- How to shutdown celery node
- How to skip corrupt (non-serializable) messages in Spring Kafka Consumer?
- How to skip record which produces runtime exception in Kafka and keep stream running?
- How to slow down or set given speed on the Kafka stream consumer?
- How to specify a byte-array serializer/deserializer in Kafka-Python
- how to specify consumer group in Kafka Spark Streaming using direct stream
- How to start Kafka listener manually?
- How to start Zookeeper and then Kafka?
- How to stop consuming message from kafka and stop calling REST API call of another service in case of failure
- How to stop consuming message from selective queue - RabbitMQ
- How to stop Python Kafka Consumer in program?
- how to stop rabbitmq servers
- How to store only latest key values in a kafka topic
- How to stream data from Kafka to MongoDB by Kafka Connector
- How to stream data from Kafka topic to Delta table using Spark Structured Streaming
- How to stream large files through Kafka?
- How to subscribe multiple topic using @KafkaListner annotation
- How to subscribe to a list of multiple kafka wildcard patterns using kafka-python?
- How to support multiple KeyBy in Flink
- How to suppress window using wall clock time instead of event time in Kafka streams?
- How to sync data for a particular user, when reading from kafka?
- How to test a ConsumerAwareRebalanceListener?
- How to test a Kafka Stream app without duplicating the topology? Use of TopologyTestDriver?
- How to test the connection to RabbitMQ Server?
- How to test whether log compaction is working or not in Kafka?
- How to transactionally poll Kafka from Camel?
- How to transfer data from S3 bucket to Kafka
- How to transform all timestamp fields when using Kafka Connect?
- How to transform and extract fields in Kafka sink JDBC connector
- How to trigger azure function when there is a message in Kafka topic
- How to use Android App as a client for Kafka?
- How to use Apache kafka with Spring mvc ? Is it possible?
- How to use Consumer API of Kafka 0.8.2?
- How to use Flink's KafkaSource in Scala?
- How to use from_json with Kafka connect 0.10 and Spark Structured Streaming?
- How to use kafka-node under typescript?
- how to use Kafka 0.8 Log4j appender
- how to use kafka acls?
- How to use kafka and storm on cloudfoundry?
- How to use Kafka connect in Strimzi
Course
Beginner
27 lessons
10 hours
System Design Fundamentals
Build a strong foundation in designing scalable, reliable distributed systems.
View the course