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

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

Kafka TOPIC_AUTHORIZATION_FAILED

apache-kafka acl jaas

Kafka sink connector: No tasks assigned, even after restart

mongodb docker apache-kafka apache-kafka-connect confluent-platform

Kafka : Deserialization issues during poll

apache-kafka kafka-consumer-api confluent-platform

Increase no of records read in single poll of KafkaConsumer

apache-kafka kafka-consumer-api

Consumer Pause & Resume works on ConsumerGroup Level?

apache-kafka kafka-consumer-api

Is there a way to stop Kafka consumer at a specific offset?

apache-kafka

can i traverse the items in a KTable from an external method

scala apache-kafka apache-kafka-streams

LEADER_NOT_AVAILABLE error in wurstmeister kafka

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

How to create kafka topic with partitions in nodejs?

node.js apache-kafka

Spark Streaming Exception: java.util.NoSuchElementException: None.get

apache-spark hadoop apache-kafka apache-spark-sql spark-streaming

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

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 »