Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in confluent-platform

Tuning S3 file sizes for Kafka

Serde class for AVRO primitive type

Confluent Platform KSQL in headless mode

ksqldb confluent-platform

Confluent Kafka: Consumer does not read from beginning for all partitions in a topic

C# Unable to consume message on Kafka topic?

Kafka Sink: ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectStandalone:130)

Kafka connect cannot find broker in docker

org.apache.kafka.common.KafkaException: io.confluent.kafka.serializers.KafkaAvroSerializer

Kafka Streams groupByKey not working due to RocksDB in Mac m1

Kafka python Consumer group session timed out

Confluent Error: set environment variable CONFLUENT_HOME

kafka connect - jdbc sink sql exception

How to properly restart a kafka s3 sink connect?

How to make consume method as non blocking in confluent kafka for dot net

How pass Basic Authentication to Confluent Schema Registry?

java.lang.NoSuchMethodError: com.google.common.collect.Sets$SetView.iterator()Lcom/google/common/collect/UnmodifiableIterator;

How to read batch messages in confluent kafka python?

ElasticsearchSinkConnector Failed to deserialize data to Avro

How to migrate consumer offsets using MirrorMaker 2.0?

NotEnoughReplicasException: The size of the current ISR Set(2) is insufficient to satisfy the min.isr requirement of 3