I am using Python Kafka topic.
Is there any provision producer that can update a message in a queue in Kafka and append it to the top of queue again?
According to spec of Kafka, it doesn't seems feasible.
According to spec of Kafka, it doesn't seems feasible.
You can modify Kafka topic properties by navigating to the Topics page, and editing content in the Configs tab of the topic Profile.
If you want to consume only the latest message from kafka topic, Please set “Auto Offset Reset” to “LATEST” and keep other values as default. If you want to consume all the message published from kafka topic Please set “Auto Offset Reset” to “EARLIEST” and keep other values as default.
Kafka is a distributed immutable commit log. That said, there is no possibility to update a message in a topic. Once it is there all you can do is consume it, update and produce to another (or this) topic again
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With