clear query| facets| time Search criteria: .   Results from 1 to 10 from 2056 (0.0s).
Loading phrases to help you
refine your search...
[expand - 7 more] - [DISCUSS] KIP-441: Smooth Scaling Out for Kafka Streams - Kafka - [mail # dev]
...Hello John,That sounds reasonable. Just double checked the code that with loggingdisabled the corresponding checkpoint file would not contain any values,just like a stateless task. So I thin...
   Author: Guozhang Wang , 2019-08-21, 18:54
[expand - 13 more] - [DISCUSS] KIP-444: Augment Metrics for Kafka Streams - Kafka - [mail # dev]
...Hello Bruno,I've updated the wiki page again per your comments, here's a brief summary:1. added the list of removed metrics.2. added a task-level INFO metric "dropped-records" that covers al...
   Author: Guozhang Wang , 2019-08-20, 18:29
[VOTE] KIP-444: Refactor and Augment Metrics for Kafka Streams - Kafka - [mail # dev]
...Hello folks,I'd like to start a voting thread the following KIP to improve the KafkaStreams metrics mechanism to users. This includes 1) renaming changes inthe public StreamsMetrics utils AP...
   Author: Guozhang Wang , 2019-08-20, 18:29
[expand - 1 more] - [VOTE] KIP-396: Add Commit/List Offsets Operations to AdminClient - Kafka - [mail # dev]
...+1 (binding).Thanks!GuozhangOn Wed, Aug 14, 2019 at 5:18 PM Vahid Hashemian wrote:> +1 (binding)>> Thanks Michael for the suggestion of simplifying offset> retrieval/alteration o...
   Author: Guozhang Wang , 2019-08-15, 20:18
[expand - 8 more] - [DISCUSS] KIP-447: Producer scalability for exactly once semantics - Kafka - [mail # dev]
...My main concern is to require the overloaded `initTransactions` to becalled repeatedly while the original `initTransactions` still called oncethroughout the life time, which is a bit confusi...
   Author: Guozhang Wang , 2019-08-14, 17:45
[VOTE] KIP-497: Add inter-broker API to alter ISR - Kafka - [mail # dev]
...+1 (binding). This is a great KIP, thanks Jason!Regarding the naming of the zkVersion, I'm actually fine to name it moregenerally and leave a note that at the moment its value is defined as ...
   Author: Guozhang Wang , 2019-08-13, 20:55
[VOTE] KIP-496: Administrative API to delete consumer offsets - Kafka - [mail # dev]
...+1 (binding).Thanks Jason!On Wed, Aug 7, 2019 at 11:18 AM Jason Gustafson  wrote:> Hi All,>> I'd like to start a vote on KIP-496:>> https://cwiki.apache.org/confluence/di...
   Author: Guozhang Wang , 2019-08-12, 17:57
[KAFKA-8729] Augment ProduceResponse error messaging for specific culprit records - Kafka - [issue]
...1. We should replace the misleading CORRUPT_RECORD error code with a new INVALID_RECORD.2. We should augment the ProduceResponse with customizable error message and indicators of culprit rec...
http://issues.apache.org/jira/browse/KAFKA-8729    Author: Guozhang Wang , 2019-08-12, 08:33
[KAFKA-8179] Incremental Rebalance Protocol for Kafka Consumer - Kafka - [issue]
...Recently Kafka community is promoting cooperative rebalancing to mitigate the pain points in the stop-the-world rebalancing protocol. This ticket is created to initiate that idea at the Kafk...
http://issues.apache.org/jira/browse/KAFKA-8179    Author: Guozhang Wang , 2019-08-12, 08:33
[expand - 1 more] - Partition assignment in kafka streams - Kafka - [mail # user]
...Hi Navneeth,In Streams you can only get your assignment at runtime via the APImentioned above, but cannot get it before the streams app starts up (Iassume that is what you meant for "upfront...
   Author: Guozhang Wang , 2019-08-08, 22:48