Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Getting acks = -1 when I set acks to all in my Kafka producer

what's the difference between kafka-preferred-replica-election.sh and auto.leader.rebalance.enable?

apache-kafka

Moving data from Snowflake to Kafka

Spring Integration Kafka Consumer

Kafka topic not created automatically on remote kafka after spring boot start(and create on local kafka server)

Apache Flink delay processing of certain events

Get kafka record timestamp from kafka message

scala apache-kafka

How to get full document when using kafka mongodb source connector when tracking update operations on a collection?

Consumer connecting to zookeeper not broker for message consumption?

java apache-kafka

How to measure the performance metrics on kafka when pushing/consuming the message to/from the topic

apache-kafka

How can I send data from kafka to hive

hive apache-kafka

Kafka s3 connect "Value is not Struct type" error

Spark (Kafka) Streaming Memory Issue

How to update KSQL stream definition dynamically based on schema-registry

Spring-Kafka: Rebalancing happening while using consumer pause/resume which should not as per documentation

apache-kafka spring-kafka

how to convert directstream from kafka into data frames in spark 1.3.0

Is there an OpenAPI type specification for Kafka or similar technology?