I need to write an application that consumes data from Kafka. The data is produced with the default partition scheme. The application cares about the current message and most recent message for any given key. In the event of the application going down (scaling in, deployment, failure), the most recent message would need to be fetched so..
Tag : apache-kafka
This connection failure error continuously logging in project, how can I stop this even when kafka server is down . I tried to remove property from application.properties
spring.kafka.producer.bootstrap-servers=localhost:9092 trying to connect using Producerconfig file i..
I’m new to the Kafka world and I’m trying to understand some things.
I know Kafka could support around 200K partitions per cluster and now with KRaft, it can go up to 2 mi..
..
On old Kafka 2.0.0.3.1.0.0-78 (HDP) we’re facing an interesting issue with ISR. So, actually
we don’t have ISR accordingly to replication factor for certain paritions. For ins..
I just installed tha kafka and run the zookeeper but cant run the kafka server with that ..
I use mirrormake2， the version of kafka is
in the source cl..
We want to install Kafka Kraft cluster on 35 machines ( machines are DELL physical machines – type R760 And OS is Linux RHEL 8.6 ver..
Kafka’s consumer reads from some partition, which has replicas. After consumer’s acknowledge the offset is updated.
Is the offset updated for the all partition’s rep..