Logo Questions Linux Laravel Mysql Ubuntu Git Menu
HTML CSS JAVASCRIPT SQL PYTHON PHP BOOTSTRAP JAVA JQUERY R React Kotlin
 

New posts in kafka-consumer-api

How to write a Spark dataframe into Kinesis Stream?

scala apache-spark apache-kafka kafka-consumer-api amazon-kinesis

Error while fetching metadata kafka {test=LEADER_NOT_AVAILABLE}?

apache-kafka kafka-consumer-api kafka-producer-api

Spring Kafka with Dynamic @KafkaListener

java spring spring-boot kafka-consumer-api spring-kafka

KafkaConsumer.commitAsync() behavior with a lower offset than previous

java apache-kafka kafka-consumer-api offset spring-kafka

Kafka: consume all messages on demand

java apache-kafka kafka-consumer-api

How to advance the consumer offset in a Kafka consumer group to the end?

apache-kafka kafka-consumer-api

reading only specific messages from kafka topic

apache-kafka kafka-consumer-api kafka-python

Spring Boot and Kafka: Failed to send SSL Close message

spring-boot apache-kafka kafka-consumer-api spring-kafka

Kafka Streams - Multiple Threads or Multiple Instances with same application id

apache-kafka kafka-consumer-api apache-kafka-streams node-kafka-streams

How do you send data from Kafka streams to clients via Websockets in PlayFramework?

scala playframework websocket apache-kafka kafka-consumer-api

What does KafkaConsumer.commitSync() actually commit?

java apache-kafka kafka-consumer-api

Why does kafka producer have client.id?

apache-kafka kafka-consumer-api kafka-producer-api

Confluent Kafka: Consumer does not read from beginning for all partitions in a topic

python apache-kafka kafka-consumer-api confluent-platform

Return from Kafka consumer when there is no message

apache-kafka kafka-consumer-api librdkafka

Flink+Kafka reset checkpoint and offset

apache-kafka kafka-consumer-api apache-flink flink-streaming

What if a Kafka's consumer handles a message too long? Will Kafka reappoint this partition to another consumer and the message will doubly handled?

apache-kafka kafka-consumer-api kafka-partition

kafka MockConsumer throwing exception error java.lang.IllegalStateException: Subscription to topics, partitions and pattern are mutually exclusive

java kafka-consumer-api

Describe Kafka Consumer Groups Response

apache-kafka kafka-consumer-api

Kafka python Consumer group session timed out

python apache-kafka kafka-consumer-api producer-consumer confluent-platform

python confluent kafka: Group authorization failed

python ssl apache-kafka kafka-consumer-api sasl
« Newer Entries Older Entries »