Hi,
I have never seen PolicyViolationException before with vanilla Kafka. What
is the flavor?
This may caused by the controller mutation rate checks introduced by
KIP-599, it may be triggered for non-existing topics but not for the
existing resources.
Hope this help you track it down.
OSB
On
Hi Kafka Dev/Users,
While running tests in `StreamThreadTest.java` in kafka/streams, I noticed
the test left many lingering threads. Though the class runs `shutdown`
after each test, the shutdown only executes `completeShutdown` if the
StreamThread is in CREATED state. See
https://github.com/apach
@Mohamed
Depending on topic retention and offset, and how much data in topic, your app
could start reprocessing lot of data and eventually struggling in terms of
performance.
[Logo, company name Description automatically generated]
Jose Manuel Vega Monroy
Software Engineer Team Leader
Direct:
Kafka 3.6.2 – thanks, Paul
From: Ömer Şiar Baysal
Date: Thursday, 11 July 2024 at 9:57 PM
To: users@kafka.apache.org
Subject: Re: Error creating a topic with 10k partitions but not altering
existing topic to 10k partitions? Why
[You don't often get email from osiarbay...@gmail.com. Learn why th
