[jira] [Resolved] (KAFKA-8434) Make global stream time consistent over all stream tasks

[ https://issues.apache.org/jira/browse/KAFKA-8434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu resolved KAFKA-8434. --- Resolution: Fixed > Make global stream time consistent over all stream tasks >

[jira] [Created] (KAFKA-8434) Make global stream time consistent over all stream tasks

Richard Yu created KAFKA-8434: - Summary: Make global stream time consistent over all stream tasks Key: KAFKA-8434 URL: https://issues.apache.org/jira/browse/KAFKA-8434 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8433) Give the opportunity to use serializers and deserializers with IntegrationTestUtils

Anthony Callaert created KAFKA-8433: --- Summary: Give the opportunity to use serializers and deserializers with IntegrationTestUtils Key: KAFKA-8433 URL: https://issues.apache.org/jira/browse/KAFKA-8433

[jira] [Resolved] (KAFKA-8246) refactor topic/group instance id validation condition

[ https://issues.apache.org/jira/browse/KAFKA-8246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8246. Resolution: Not A Problem Since it's only one time validation, we don't need to refactor. >

[jira] [Created] (KAFKA-8432) Add static membership to Sticky assignor

Boyang Chen created KAFKA-8432: -- Summary: Add static membership to Sticky assignor Key: KAFKA-8432 URL: https://issues.apache.org/jira/browse/KAFKA-8432 Project: Kafka Issue Type: Sub-task

Re: [DISCUSS] KIP-401 TransformerSupplier/ProcessorSupplier enhancements

Per Matthias's suggestion from a while ago, I actually implemented a good amount of option B to get a sense of the user experience and documentation requirements. For a few reasons mentioned below, I think it's not my favorite option, and I prefer option C. But since I did the work and it can

Re: Contributor Apply

nit: You can *now* self-assign tickets. On Fri, May 24, 2019 at 11:30 PM Matthias J. Sax wrote: > Added you to the list on contributors. You can not self-assign tickets. > > Please read > https://cwiki.apache.org/confluence/display/KAFKA/Contributing+Code+Changes > to get started. > > > >

[jira] [Created] (KAFKA-8431) Add a onTimeoutExpired callback to Kafka Consumer

Richard Yu created KAFKA-8431: - Summary: Add a onTimeoutExpired callback to Kafka Consumer Key: KAFKA-8431 URL: https://issues.apache.org/jira/browse/KAFKA-8431 Project: Kafka Issue Type:

[DISCUSS] KIP-474: To deprecate WindowStore#put(key, value)

We propose to deprecate the WindowStore#put(key, value), as it does not have a timestamp as a parameter. The window store requires a timestamp to map the key to a window frame. This method uses the current record timestamp(as specified in the description of the method). There is a method present