clear query| facets| time Search criteria: .   Results from 1 to 10 from 53 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-6145] Warm up new KS instances before migrating tasks - potentially a two phase rebalance - Kafka - [issue]
...Currently when expanding the KS cluster, the new node's partitions will be unavailable during the rebalance, which for large states can take a very long time, or for small state stores even ...
http://issues.apache.org/jira/browse/KAFKA-6145    Author: Antony Stubbs , 2020-05-27, 22:49
[KAFKA-6182] Automatic co-partitioning of topics via automatic intermediate topic with matching partitions - Kafka - [issue]
...Currently it is up to the user to ensure that two input topics for a join have the same number of partitions, and if they don't, manually create an intermediate topic, and send the stream #t...
http://issues.apache.org/jira/browse/KAFKA-6182    Author: Antony Stubbs , 2020-05-18, 17:48
[KAFKA-6943] Have option to shutdown KS cleanly if any threads crashes, or if all threads crash - Kafka - [issue]
...ATM users have to implement this themselves. Might be nice to have an option to configure that if all threads crash, or if any crash, to initiate clean shutdown.This also has a gotcha where ...
http://issues.apache.org/jira/browse/KAFKA-6943    Author: Antony Stubbs , 2020-05-18, 17:44
[KAFKA-6910] Ability to specify a default state store type or factory - Kafka - [issue]
...For large projects, it's a huge pain and not really practically at all to use a custom state store everywhere just to use in memory or avoid rocksdb, for example for running a test suite on ...
http://issues.apache.org/jira/browse/KAFKA-6910    Author: Antony Stubbs , 2020-04-10, 16:29
[KAFKA-6144] Allow serving interactive queries from in-sync Standbys - Kafka - [issue]
...Currently when expanding the KS cluster, the new node's partitions will be unavailable during the rebalance, which for large states can take a very long time, or for small state stores even ...
http://issues.apache.org/jira/browse/KAFKA-6144    Author: Antony Stubbs , 2020-01-29, 17:43
[KAFKA-6542] Tables should trigger joins too, not just streams - Kafka - [issue]
...At the moment it's quite possible to have a race condition when joining a stream with a table, if the stream event arrives first, before the table event, in which case the join will fail.Thi...
http://issues.apache.org/jira/browse/KAFKA-6542    Author: Antony Stubbs , 2019-11-10, 08:13
[KAFKA-8884] Improve streams errors on class cast exception in ProcessorsNodes - Kafka - [issue]
...https://github.com/apache/kafka/pull/7309 If a processor causes a class cast exception, atm you get a bit of a cryptic error if you're not used to them, and without a context sensitive sugge...
http://issues.apache.org/jira/browse/KAFKA-8884    Author: Antony Stubbs , 2019-10-17, 07:25
[KAFKA-6080] Transactional EoS for source connectors - Kafka - [issue]
...Exactly once (eos) message production for source connectors....
http://issues.apache.org/jira/browse/KAFKA-6080    Author: Antony Stubbs , 2019-10-16, 15:51
[DISCUSS] KIP-470: TopologyTestDriver test input and output usability improvements - Kafka - [mail # dev]
...Hi Jukka! I just came across your work - it looks great! I was taking astab at improving the existing API, but yours already looks great and justabout complete! Are you planning on continuin...
   Author: Antony Stubbs , 2019-09-05, 14:17
[KAFKA-8648] Console tools should fail fast if an unrecognised --property is passed in - Kafka - [issue]
...Some people don't realise that the --property for the console producer and consumer, is for passing options to the formatter, not the actual producer or consumer.If someone that doesn't know...
http://issues.apache.org/jira/browse/KAFKA-8648    Author: Antony Stubbs , 2019-07-11, 18:44