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 consumer - assign and seek

java apache-kafka kafka-consumer-api

How to solve ERROR Executor - Exception in task 0.0 in stage 20.0 (TID 20)?

python apache-spark pyspark apache-kafka spark-streaming

Microservices, REST, event sourcing and data consistency

rest apache-kafka domain-driven-design microservices event-sourcing

Converting Spark-kafka InputDStream to Array[Bytes]

scala apache-spark apache-kafka spark-streaming avro

Spark Streaming and ElasticSearch - Could not write all entries

elasticsearch apache-kafka spark-streaming

How many times kafka stream invokes poll() for fetching records from kafka topic

apache-kafka apache-kafka-streams

Kafka PointToPoint

java jms apache-kafka

Kafka consuming the latest message again when I rerun the Flink consumer

apache-kafka apache-flink

Not able to run Kafka Connect in distributed mode - Error while attempting to create/ find topics 'connect-offsets'

apache-kafka apache-kafka-connect

Exception: partition is not a recognized option, when creating a kafka topic inside a docker.

apache-kafka docker-compose

Clarification on the --broker-list option and --bootstrap-server option in Kafka-console producer and consumer respectively

apache-kafka

@KafkaListener vs ConsumerFactory groupId

apache-kafka kafka-consumer-api spring-kafka

Java set Kafka retention time in source code

java apache-kafka spring-kafka

Unable to start Zookeeper server in Apache Kafka

java apache-kafka apache-zookeeper

Can i do some stateful operations in peek or filter or branch of kafka stream apps?

filter apache-kafka apache-kafka-streams stateful

Exposing Kafka cluster in Kubernetes using LoadBalancer service

kubernetes apache-kafka
« Newer Entries Older Entries »