Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in 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

Issue to access KSQL CLI on Docker

Kafka Consumer poll and reconnection

Consuming nested JSON message from Kafka with ClickHouse

How to set StorageLevel.MEMORY_AND_DISK_SER for KafkaUtils.createDirectStream?

Sending logs to Kafka with log4j2

java apache-kafka

Kafka Streams : Stream Thread failed to lock State Directory