Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

AssertionError: Unassigned partition

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