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

New posts in apache-kafka

Kafka - org.apache.kafka.common.errors.NetworkException

apache-kafka kafka-producer-api

Spark Structured Streaming with Kafka - How to repartition the data and distribute the processing among worker nodes

scala apache-spark apache-kafka spark-structured-streaming spark-kafka-integration

Kafka Stream Chained LeftJoin - Processing previous old message again after the new one

java apache-kafka left-join apache-kafka-streams

Kafka not receiving messages when indicating group_id in Python

python apache-kafka kafka-consumer-api consumer kafka-python

How does Consumer.endOffsets work in Kafka?

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

Cannot connect to Kafka from Flask in a dockerized environement

python docker flask apache-kafka connection

What are the practical limits of Kafka regex-topics / listening to multiple topics

apache-kafka publish-subscribe telemetry kafka-topic

How to dynamically add consumers in consumer group kafka

apache-kafka kafka-producer-api

How to process logs from distributed log broker (Eg Kafka) exactly after 1 week?

java python apache-spark apache-kafka apache-storm

How to get kafka message's headers in Kafka Connect Sink connector with MongoDB

apache-kafka apache-kafka-connect mongodb-kafka-connector

How to implement request-reply (synchronous) messaging paradigm in Kafka?

python apache-kafka synchronous kafka-python

Spark Structured Streaming program that reads from non-empty Kafka topic (starting from earliest) triggers batches locally, but not on EMR cluster

apache-spark apache-kafka amazon-emr spark-structured-streaming

Using Apache Kafka for log aggregation

node.js webserver apache-kafka syslog-ng

storm nimbus not starting: Getting below error

hadoop apache-kafka apache-storm

kafka: what do 'soTimeout', 'bufferSize' and 'minBytes' mean for SimpleConsumer?

apache-kafka kafka-consumer-api

Apache Spark-Kafka.TaskCompletionListenerException & KafkaRDD$KafkaRDDIterator.close NPE on local cluster(Client Mode)

java hadoop apache-spark apache-kafka spark-streaming

Rereading message from Kafka topic by refusing acknowledgement

spring-integration apache-kafka

Kafka Streams 2.5.0 requires input topic

apache-kafka-streams apache-kafka

Got user-level KeeperException when processing

apache-kafka apache-zookeeper

Apache kafka: Failed to acquire lock on file .lock in tmp/kafka-logs

apache-kafka
« Newer Entries Older Entries »