New posts in apache-kafka

org.apache.kafka.common.errors.TimeoutException: Topic not present in metadata after 60000 ms

java windows apache-kafka kafka-producer-api

From Kafka json message to Snowflake table

json apache-kafka snowflake-cloud-data-platform apache-kafka-connect

Apple M1: can't start the confluent control center using docker

docker apache-kafka confluent-platform apple-m1 confluent-control-center

Which directory does apache kafka store the data in broker nodes

zookeeper is not a recognized option when executing kafka-console-consumer.sh

java apache-kafka apache-zookeeper

How to change start offset for topic?

apache-kafka offset

How to transform a Kafka Stream event and send it to another topic only if could be transformed

scala apache-kafka apache-kafka-streams

Handling bad messages using Kafka's Streams API

error-handling apache-kafka apache-kafka-streams

How to see the retention for a particular topic in kafka

apache-kafka retention

Structured streaming schema from Kafka JSON - query error

apache-spark pyspark apache-kafka apache-spark-sql spark-structured-streaming

How do I set the Java options for Kafka?

java apache-kafka

How to integrate Oracle and Kafka

oracle apache-kafka change-data-capture oracle-streams

Topics, partitions and keys

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

What is a simple, effective way to debug custom Kafka connectors?

java debugging apache-kafka slf4j apache-kafka-connect

difference between groupid and consumerid in Kafka consumer

apache-kafka kafka-consumer-api

Kafka 0.11 how to reset offsets

Zookeeper & Kafka error KeeperErrorCode=NodeExists

windows apache-kafka apache-zookeeper

Synchronising transactions between database and Kafka producer

apache-kafka spring-transactions spring-kafka distributed-transactions

Why I cannot connect to Kafka from outside?

docker amazon-ec2 apache-kafka virtual-machine

classpath is empty. please build the project first

apache-kafka apache-zookeeper