vamossagar12
vamossagar12
Based upon the theory provided in the official jdbc documentation, I have added a condition to include both Short and Byte as INT8 types in ConnectSchema. Here's the doc: 8.3.5...
When a herder starts ,its KafkaOffsetBackingStore will readToLogEnd() by DistributedHerder.herderExecutor of name "Distrubuted-connect-" thread , e.g . Distrubuted-connect-28-1 , which may consume a few minutes. If another thread tries to...
Downgrading Connect rebalancing protocol from incremental to eager causes duplicate task instances. This PR aims to address this issue .
1) Added relevant APIResponses for all API endpoints. 2) Documented response codes/query-parameters/path-parameters/request body for all Connect related API endpoints.
Currently, the Incremental rebalance protocol does not allow a subsequent revoking rebalance when a worker joins right after one. This can lead to imbalance in assignments. See [KAFKA-12495](https://issues.apache.org/jira/browse/KAFKA-12495) for more...
Currently the producer.send() method has different mechanisms of throwing exceptions when EOS is enabled and when it is not. Furthermore, the exceptions returned in callbacks are also different at times...
WindowedStore and SessionStore do not implement a strict retention time in general. We should consider to make retention time strict: even if we still have some record in the store...
*More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing...
Hi, While trying to run the python script using the examples provided, I keep getting stuck at 1 point. I have configured everything and influx jolokia are propelry setup. But...
Problem description is [KAFKA-10840](https://issues.apache.org/jira/browse/KAFKA-10840). The implication of this behaviour is that users of Producer client never fail and keep retrying. This is true for connect for example where `max.block.ms` is...