Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

New posts in apache-kafka

Why doesn't a KSQL stream not return/show data from messages on topic in broker?

apache-kafka ksqldb

Kafka off-heap memory leak

Can i add topics to my @kafkalistener at runtime

How to run a Kafka connect worker in YARN?

Kafka Connector for Azure Blob Storage

Kafka python Consumer group session timed out

encrypted keystore /trustedstore password for Kafka broker

Kafka producer fails with expiring 2 record(s) for myTopic-1:120004 ms has passed since batch creation

java apache-kafka

python confluent kafka: Group authorization failed

Strimzi operator Kafka cluster ACL not enabling with type: simple

Alpakka Consumer not consuming messages from Kafka running via Docker compose

Kafka Reduce Lag for Consumer

Kafka: is it better to have a lot of small messages or fewer, but bigger ones?

How to retrieve zookeeper host details from Kafka brokerslist

Kafka - How to obtain failed messages details in Producer class

Kafka - From JSON records to Parquet files in S3

Kafka UNKNOWN_PRODUCER_ID exception

Sending using KafkaTemplate<String, String> returns a exception for using String as a key

Where to set parameters min.insync.replicas and acks in Java?

Kafka TestContainer tries to connect to wrong address