New posts in apache-kafka

Java Lang Null Pointer Error connecting DB2 iOS with Debezium and Kakfa Connect for CDC pull

java apache-kafka db2 debezium

How to decode/deserialize Avro with Python from Kafka

python apache-kafka avro

confluent platform vs apache kafka [closed]

apache-kafka confluent-platform

How to stop Spring Kafka Listner and invoke some function to execute after the Consumer is stopped?

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

What do the state and coordinator columns in AKHQ mean?

Spring Boot Embedded Kafka can't connect

java spring-boot kotlin apache-kafka confluent-platform

Webhook data to Kafka Connect

apache-kafka webhooks apache-kafka-connect

Kafka Msg VS REST Calls

rest apache-kafka microservices kafka-consumer-api spring-kafka

Sink connector looking for topic -value schema instead of record name

apache-kafka avro apache-kafka-connect confluent-schema-registry

What are the advantages and disadvantages of Kafka over Apache Pulsar [closed]

apache-kafka apache-pulsar

Kafka + Zookeeper: Connection to node -1 could not be established. Broker may not be available

apache-kafka apache-zookeeper

What are Apache Kafka topic name limitations?

How to read data using Kafka Consumer API from beginning?

apache-kafka kafka-consumer-api

Successor to deprecated FlinkKafkaProducer

java apache-kafka apache-flink

Why is Kafka pull-based instead of push-based?

The input line is too long when starting kafka

java apache-kafka

Increase the number of messages read by a Kafka consumer in a single poll

How does an offset expire for an Apache Kafka consumer group?

How to expose a headless service for a StatefulSet externally in Kubernetes

apache-kafka kubernetes

When does the Apache Kafka client throw a "Batch Expired" exception?

java apache-kafka ibm-cloud message-hub