clear query| facets| time Search criteria: .   Results from 1 to 10 from 1688 (0.0s).
Loading phrases to help you
refine your search...
Kafka Streams incorrect aggregation results when re-balancing occurs - Kafka - [mail # user]
...> So with>> exactly_once, it must roll-back commit(s) to the state store in a failure>> scenario?Yes. Dirty writes into the stores are "cleaned up" if you enableexactly-once p...
   Author: Matthias J. Sax , 2019-08-21, 07:17
Restructure data in GlobakKTable - Kafka - [mail # user]
...Sounds reasonable.Note that a `GlobalKTable` is designed to read data from an topic onlywithout further processing. That's why you don't get any "outputstream". For fault-tolerance, the inpu...
   Author: Matthias J. Sax , 2019-08-21, 06:48
[expand - 2 more] - [DISCUSS] KIP-360: Improve handling of unknown producer - Kafka - [mail # dev]
...Thanks for the KIP. I just have some clarification questions to makesure I understand the proposal correctly:1) "Safe Epoch Incrementing"> When the coordinator receives a new InitProducer...
   Author: Matthias J. Sax , 2019-08-21, 00:45
[VOTE] KIP-401: TransformerSupplier/ProcessorSupplier StateStore connecting - Kafka - [mail # dev]
...+1 (binding)On 6/17/19 2:32 PM, John Roesler wrote:> I'm +1 (nonbinding) on the current iteration of the proposal.> > On Mon, May 27, 2019 at 1:58 PM Paul Whalen  wrote:>>...
   Author: Matthias J. Sax , 2019-08-20, 22:28
[expand - 7 more] - [DISCUSS] KIP-401 TransformerSupplier/ProcessorSupplier enhancements - Kafka - [mail # dev]
...Thanks Paul!On 8/15/19 7:28 PM, Paul Whalen wrote:> I updated the KIP (and PR) to relax the restriction on connecting state> stores via either means; it definitely makes sense to me at...
   Author: Matthias J. Sax , 2019-08-20, 22:28
[KAFKA-7499] Extend ProductionExceptionHandler to cover serialization exceptions - Kafka - [issue]
...In KIP-210, an exception handler for the write path was introduced. This exception handler covers exception that are raised in the producer callback.However, serialization happens before the...
http://issues.apache.org/jira/browse/KAFKA-7499    Author: Matthias J. Sax , 2019-08-20, 22:21
list of pattern processed topic list - Kafka - [mail # user]
...#listTopic() is not related to your subscription/assignment as indicatedby its JavaDocs:> Get metadata about partitions for all topics that the user is authorized to view. This method wil...
   Author: Matthias J. Sax , 2019-08-20, 18:17
[KAFKA-8821] Avoid pattern subscription to allow for stricter ACL settings - Kafka - [issue]
...To avoid triggering auto topic creation (if `auto.create.topic.enable=true` on the brokers), Kafka Streams uses consumer pattern subscription. For this case, the consumer requests all metada...
http://issues.apache.org/jira/browse/KAFKA-8821    Author: Matthias J. Sax , 2019-08-20, 18:03
[KAFKA-8661] Flaky Test RebalanceSourceConnectorsIntegrationTest#testStartTwoConnectors - Kafka - [issue]
...https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/224/testReport/junit/org.apache.kafka.connect.integration/RebalanceSourceConnectorsIntegrationTest/testStartTwoConnectors/java.lang.Ass...
http://issues.apache.org/jira/browse/KAFKA-8661    Author: Matthias J. Sax , 2019-08-19, 20:00
[KAFKA-8391] Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector - Kafka - [issue]
...https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/4747/testReport/junit/org.apache.kafka.connect.integration/RebalanceSourceConnectorsIntegrationTest/testDeleteConnector/java.lang.Asser...
http://issues.apache.org/jira/browse/KAFKA-8391    Author: Matthias J. Sax , 2019-08-19, 19:59