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

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

After Linux restart, Kafka throwing "no brokers found when trying to rebalance"

linux apache-kafka apache-zookeeper

Delayed Queue implementation in Storm – Kafka, Cassandra, Redis or Beanstalk?

java message-queue apache-kafka apache-storm delayed-execution

Spring Boot Kafka Startup error "Connection to node -1 could not be established. Broker may not be available."

spring spring-boot apache-kafka spring-kafka

Kafka Streams 2.5.0 requires input topic

apache-kafka-streams apache-kafka

Apache Kafka error on windows - Couldnot find or load main class QuorumPeerMain

apache-kafka apache-zookeeper

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 »