clear query| facets| time Search criteria: .   Results from 1 to 10 from 1967 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-6453] Reconsider timestamp propagation semantics - Kafka - [issue]
...Atm, Kafka Streams only has a defined "contract" about timestamp propagation at the Processor API level: all processor within a sub-topology, see the timestamp from the input topic record an...
http://issues.apache.org/jira/browse/KAFKA-6453    Author: Matthias J. Sax , 2020-07-09, 18:11
[KAFKA-10036] Improve error message if user violates `Supplier` pattern - Kafka - [issue]
...Using the Processor API, users need to pass in a `ProcessorSupplier` that needs to return new `Processor` instance each time `get()` is called.Users violate this rule on a regular basis and ...
http://issues.apache.org/jira/browse/KAFKA-10036    Author: Matthias J. Sax , 2020-07-09, 09:59
[VOTE] KIP-431: Support of printing additional ConsumerRecord fields in DefaultMessageFormatter - Kafka - [mail # dev]
...+1 (binding)-MatthiasOn 7/7/20 7:16 PM, John Roesler wrote:> Hi Badai,> > Thanks for picking this up. I've reviewed the KIP document and> the threads you linked. I think we may w...
   Author: Matthias J. Sax , 2020-07-08, 06:17
[VOTE] KIP-622 Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContext - Kafka - [mail # dev]
...Thanks for the KIP.+1 (binding)-MatthiasOn 7/7/20 11:48 AM, William Bottrell wrote:> Hi everyone,> > I'd like to start a vote for adding two new time API's to ProcessorContext.> ...
   Author: Matthias J. Sax , 2020-07-08, 06:12
[expand - 1 more] - [DISCUSS] KIP-622 Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContext - Kafka - [mail # dev]
...I think, we don't need a default implementation for the new methods.What would be the use-case to implement the  `ProcessorContext`interface? In contract to, for example, `KeyValueStore...
   Author: Matthias J. Sax , 2020-07-08, 06:11
[KAFKA-8264] Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition - Kafka - [issue]
...https://builds.apache.org/blue/organizations/jenkins/kafka-2.0-jdk8/detail/kafka-2.0-jdk8/252/testsorg.apache.kafka.common.errors.TopicExistsException: Topic 'topic3' already exists.STDOUT &...
http://issues.apache.org/jira/browse/KAFKA-8264    Author: Matthias J. Sax , 2020-07-07, 09:36
Potential Improvement for Kafka Producer - Kafka - [mail # dev]
...Arvin,thanks for your email. This is definitely the right channel. I ampersonally not familiar enough with the producer code, but what you saymakes sense to me from a high level.Maybe it wou...
   Author: Matthias J. Sax , 2020-07-06, 19:30
[DISCUSS] KIP-406: GlobalStreamThread should honor custom reset policy - Kafka - [mail # dev]
...Atm, the config should be ignored and the global-consumer should use"none" in a hard-coded way.However, if am still wondering if we actually want/need to allow usersto specify the reset poli...
   Author: Matthias J. Sax , 2020-07-06, 19:23
[expand - 14 more] - [DISCUSSION] KIP-418: A method-chaining way to branch KStream - Kafka - [mail # dev]
...I am happy with the KIP. Was actually waiting for John to reply :)On 6/26/20 11:06 AM, John Roesler wrote:> Hello Ivan,> > I’m sorry for the delay. I was waiting to see if Matthias ...
   Author: Matthias J. Sax , 2020-07-06, 18:44
[VOTE] KIP-418: A method-chaining way to branch KStream - Kafka - [mail # dev]
...I am late, but I am also +1 (binding).-MatthiasOn 7/6/20 2:16 AM, Ivan Ponomarev wrote:> Wow!> > So excited to hear that!> > Thanks for your collaboration, now it's my turn to...
   Author: Matthias J. Sax , 2020-07-06, 18:43