ReplicaManager fetch fails on leader due to long/integer overflow

Hi, I’m having what seems to be this issue: https://issues.apache.org/jira/browse/KAFKA-7656 It happens when a transactional producer sends an event for the 1st time. ``` ERROR [

Rebalancing stuck, never finishes

Hi, I have an application running with 6 instances of it on Kubernetes. All 6 instances (pods) are the same, using the same consumer group id. Recently we see that when the application is restarted (rolling restart on K8s), the triggered rebalancing sometimes doesn't finish at all and the Kafka Cl

Re: Unable to run unit tests inside a docker container

WHY BUILD ENVIRONMENTS MATTER in maven land and in ant land every published maven/ant artifact is backwardly compatible with previous versions so my scala version 2.13.3 plugin should not fail any build because scala plugin has a hardcoded scala plugin of 2.12.13 (your version) if this is the cas

KStreams: TimeoutException on restore consumer impacts active tasks

Hi, We are running KStreams application (2.6.1) with standby replicas set to 1. Recently one of the instances had an unexpected behaviour. We observed several DisconnectExceptions & TimeoutException in logs due to request timeouts for a single stream thread, logged by the internal restore consume

Re: KStreams: TimeoutException on restore consumer impacts active tasks

Well, first of all, in current releases if any timeout exception happens, the corresponding thread dies. Thus, if a standby task throws, it would impact the active tasks of the same thread and the thread dies and all active and standby tasks need to redistributed to remaining threads/instances via