Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

kafka streams groupBy aggregate produces unexpected values

How to make bitnami/kafka accessible from external via clusterip

How I receive the last windowed Kafka message in a windowedBy+aggregate when producer stops to send messages in Java/Spring?

How Kafka producers manage the connections

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