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 streams - joining partitioned topics

apache-kafka apache-kafka-streams

Failed to find any class that implements Connector and which name matches com.mongodb.kafka.connect.MongoSinkConnector

apache-kafka apache-kafka-connect

Installing librdkafka on Windows for PHP XAMPP

php apache-kafka queue

How to map types using properties file in Kafka

java apache-kafka kafka-consumer-api

Migrate kafka client to latest version

java apache-kafka

Ideal configuration setting for max.tasks for Kafka Source Connector

apache-kafka apache-kafka-connect

Can Kafka be used as a distribute work queue

java apache-kafka distributed-computing software-design

What happens to consumer offsets if a new partition(s) is added to a Kafka topic?

apache-kafka

How can I prevent the "Telemetry client instance id changed from AAAAAAAAAAAAAAAAAAAAAA to" log in a confluent-kafka-python consumer?

python kubernetes apache-kafka confluent-kafka-python

Recovering Kafka clients (consumers/producers) after they went down

spring-boot apache-kafka spring-kafka

How to check which zookeeper instance is the leader within an ensemble

apache-kafka apache-zookeeper

Is it better to keep a Kafka Producer open or to create a new one for each message?

apache-kafka rabbitmq kafka-producer-api

Dataflow reading from Kafka without data loss?

google-cloud-platform apache-kafka google-cloud-dataflow apache-beam

How to finish kafka consumer safety?(Is there meaning to call thread#join inside shutdownHook ? )

java multithreading apache-kafka kafka-consumer-api shutdown-hook

Skip record if Exception occurs in Topology

exception apache-kafka apache-kafka-streams

Not acknowledging the kafka message at all in MANUAL_IMMEDIATE mode

apache-kafka kafka-consumer-api spring-kafka

kafka partition rebalancing (assignment) is taking too much time

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

How to choose Kafka transaction id for several applications, hosted in Kubernetes?

java kubernetes apache-kafka spring-kafka kafka-producer-api

Spring boot Kafka Consumer Bootstrap Servers always picking Localhost 9092

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

debezium sqlserver connector outputs encoded values for numeric/decimal fields

sql-server apache-kafka confluent-platform connector debezium
« Newer Entries Older Entries »