Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

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?

Client ID authentication no longer works with Kafka API

Deleting and re-creating Kafka topics through the Java KafkaServer API

apache-kafka

Kafka Connect: could not get type for name org.osgi.framework.BundleListener on Windows