Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Spring Kafka - Encountering "Magic v0 does not support record headers" error

Spring Boot and Kafka: Broker disconnected

Spring boot Rest api with Spring 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?