Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Can I Use SSL and ACL authentication/authorization only for SSL listener (not for PLAINTEXT) in Kafka?

BATCH vs MANUAL and ack vs commit

apache-kafka spring-kafka

log4j2 kafka appender over TLS/SSL

java ssl apache-kafka log4j2

how to set kafka connect auto.offset.reset with rest api

EmbeddedKafka sending messages to consumer after delay in subsequent test

Kafka independent consumers

@KafkaListener is not consuming messages - issue with deserialization

How can I use keystore.jks and truststore.jks files for Kafka Python SSL Authentication after converting to .pem?

Difference in key/value subjects in Schema Registry

Spring Kafka consumer not able to consume records

How to find first message which is not deleted in Kafka topic

Exception in thread "StreamThread-1" org.apache.kafka.streams.errors.StreamsException: Failed to rebalance

Produce Avro messages in Confluent Control Center UI

Multiple postgres connections with debezium connector

Kafka Streams local state stores

Debezium Postgres sink connector fails to insert values with type DATE