[jira] [Commented] (KAFKA-3775) Throttle maximum number of tasks assigned to a single KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-3775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322254#comment-15322254 ] Matthias J. Sax commented on KAFKA-3775: I want to push this discussion further. As [~guozhang]

[jira] [Commented] (KAFKA-3775) Throttle maximum number of tasks assigned to a single KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-3775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327326#comment-15327326 ] Matthias J. Sax commented on KAFKA-3775: [~tenggyut] [~wushujames] Kafka Streams allow to specify

[jira] [Commented] (KAFKA-3576) Unify KStream and KTable API

[ https://issues.apache.org/jira/browse/KAFKA-3576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15328242#comment-15328242 ] Matthias J. Sax commented on KAFKA-3576: I see two points: (1) this is similar to SQL / Pig or

[jira] [Commented] (KAFKA-3775) Throttle maximum number of tasks assigned to a single KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-3775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15312250#comment-15312250 ] Matthias J. Sax commented on KAFKA-3775: I have some concerns about this: 1) a KStreams

[jira] [Created] (KAFKA-3880) Disallow Join Windows with size zero

Matthias J. Sax created KAFKA-3880: -- Summary: Disallow Join Windows with size zero Key: KAFKA-3880 URL: https://issues.apache.org/jira/browse/KAFKA-3880 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-3185) Allow users to cleanup internal data

[ https://issues.apache.org/jira/browse/KAFKA-3185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-3185: -- Assignee: Matthias J. Sax > Allow users to cleanup internal data >

[jira] [Assigned] (KAFKA-3337) Extract selector as a separate groupBy operator for KTable aggregations

[ https://issues.apache.org/jira/browse/KAFKA-3337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-3337: -- Assignee: Matthias J. Sax > Extract selector as a separate groupBy operator for KTable

[jira] [Assigned] (KAFKA-3477) Add customizable StreamPartition into #to functions of Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-3477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-3477: -- Assignee: Matthias J. Sax > Add customizable StreamPartition into #to functions of

[jira] [Updated] (KAFKA-3598) Improve JavaDoc of public API

[ https://issues.apache.org/jira/browse/KAFKA-3598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3598: --- Status: Patch Available (was: In Progress) > Improve JavaDoc of public API >

[jira] [Updated] (KAFKA-3599) Minor code cleanup

[ https://issues.apache.org/jira/browse/KAFKA-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3599: --- Status: Patch Available (was: In Progress) > Minor code cleanup > -- > >

[jira] [Updated] (KAFKA-3599) Minor code cleanup

[ https://issues.apache.org/jira/browse/KAFKA-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3599: --- Description: - remove {{WindowStoreUtils}} from public API, ie, move to sub-package

[jira] [Updated] (KAFKA-3599) Move WindowStoreUtils to package "internals"

[ https://issues.apache.org/jira/browse/KAFKA-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3599: --- Summary: Move WindowStoreUtils to package "internals" (was: Minor code cleanup) > Move

[jira] [Commented] (KAFKA-3599) Minor code cleanup

[ https://issues.apache.org/jira/browse/KAFKA-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15255733#comment-15255733 ] Matthias J. Sax commented on KAFKA-3599: Removing the `equals()` issue from this JIRA because this

[jira] [Updated] (KAFKA-3440) Add Javadoc for KTable (changelog stream) and KStream (record stream)

[ https://issues.apache.org/jira/browse/KAFKA-3440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3440: --- Status: Patch Available (was: In Progress) > Add Javadoc for KTable (changelog stream) and

[jira] [Updated] (KAFKA-3440) Add Javadoc for KTable (changelog stream) and KStream (record stream)

[ https://issues.apache.org/jira/browse/KAFKA-3440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3440: --- Description: Currently we only have a 1-liner in {code}KTable{code} and {code}KStream{code}

[jira] [Updated] (KAFKA-3440) Add Javadoc for KTable (changelog stream) and KStream (record stream)

[ https://issues.apache.org/jira/browse/KAFKA-3440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3440: --- Description: Currently we only have a 1-liner in {code}KTable{code} and {code}KStream{code}

[jira] [Work started] (KAFKA-3440) Add Javadoc for KTable (changelog stream) and KStream (record stream)

[ https://issues.apache.org/jira/browse/KAFKA-3440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3440 started by Matthias J. Sax. -- > Add Javadoc for KTable (changelog stream) and KStream (record stream) >

[jira] [Assigned] (KAFKA-3574) Add missing @returns tags for JavaDoc

[ https://issues.apache.org/jira/browse/KAFKA-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-3574: -- Assignee: Matthias J. Sax (was: Guozhang Wang) > Add missing @returns tags for

[jira] [Assigned] (KAFKA-3440) Add Javadoc for KTable (changelog stream) and KStream (record stream)

[ https://issues.apache.org/jira/browse/KAFKA-3440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-3440: -- Assignee: Matthias J. Sax > Add Javadoc for KTable (changelog stream) and KStream

[jira] [Closed] (KAFKA-3574) Add missing @returns tags for JavaDoc

[ https://issues.apache.org/jira/browse/KAFKA-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed KAFKA-3574. -- > Add missing @returns tags for JavaDoc > - > >

[jira] [Resolved] (KAFKA-3574) Add missing @returns tags for JavaDoc

[ https://issues.apache.org/jira/browse/KAFKA-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3574. Resolution: Duplicate > Add missing @returns tags for JavaDoc >

[jira] [Work started] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations

[ https://issues.apache.org/jira/browse/KAFKA-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3429 started by Matthias J. Sax. -- > Remove Serdes needed for repartitioning in KTable stateful operations >

[jira] [Created] (KAFKA-3576) Unify KStream and KTable API

Matthias J. Sax created KAFKA-3576: -- Summary: Unify KStream and KTable API Key: KAFKA-3576 URL: https://issues.apache.org/jira/browse/KAFKA-3576 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-3576) Unify KStream and KTable API

[ https://issues.apache.org/jira/browse/KAFKA-3576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3576: --- Fix Version/s: 0.10.1.0 > Unify KStream and KTable API > > >

[jira] [Assigned] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations

[ https://issues.apache.org/jira/browse/KAFKA-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-3429: -- Assignee: Matthias J. Sax > Remove Serdes needed for repartitioning in KTable stateful

[jira] [Created] (KAFKA-3574) Add missing @returns tags for JavaDoc

Matthias J. Sax created KAFKA-3574: -- Summary: Add missing @returns tags for JavaDoc Key: KAFKA-3574 URL: https://issues.apache.org/jira/browse/KAFKA-3574 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-3574) Add missing @returns tags for JavaDoc

[ https://issues.apache.org/jira/browse/KAFKA-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3574: --- Issue Type: Sub-task (was: Improvement) Parent: KAFKA-2590 > Add missing @returns

[jira] [Commented] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations

[ https://issues.apache.org/jira/browse/KAFKA-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245384#comment-15245384 ] Matthias J. Sax commented on KAFKA-3429: Ok. This does not contradict my thoughts. In general, we

[jira] [Commented] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations

[ https://issues.apache.org/jira/browse/KAFKA-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15244771#comment-15244771 ] Matthias J. Sax commented on KAFKA-3429: [~guozhang] I am a little confused here:

[jira] [Work started] (KAFKA-3337) Extract selector as a separate groupBy operator for KTable aggregations

[ https://issues.apache.org/jira/browse/KAFKA-3337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3337 started by Matthias J. Sax. -- > Extract selector as a separate groupBy operator for KTable aggregations >

[jira] [Work started] (KAFKA-3598) Improve JavaDoc of public API

[ https://issues.apache.org/jira/browse/KAFKA-3598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3598 started by Matthias J. Sax. -- > Improve JavaDoc of public API > - > >

[jira] [Updated] (KAFKA-3598) Improve JavaDoc of public API

[ https://issues.apache.org/jira/browse/KAFKA-3598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3598: --- Description: Add missing JavaDoc to all {{public}} methods of public API. Is related to

[jira] [Created] (KAFKA-3599) Minor code cleanup

Matthias J. Sax created KAFKA-3599: -- Summary: Minor code cleanup Key: KAFKA-3599 URL: https://issues.apache.org/jira/browse/KAFKA-3599 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-3598) Improve JavaDoc of public API

Matthias J. Sax created KAFKA-3598: -- Summary: Improve JavaDoc of public API Key: KAFKA-3598 URL: https://issues.apache.org/jira/browse/KAFKA-3598 Project: Kafka Issue Type: Sub-task

[jira] [Work started] (KAFKA-3599) Minor code cleanup

[ https://issues.apache.org/jira/browse/KAFKA-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3599 started by Matthias J. Sax. -- > Minor code cleanup > -- > > Key:

[jira] [Commented] (KAFKA-3599) Minor code cleanup

[ https://issues.apache.org/jira/browse/KAFKA-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15251933#comment-15251933 ] Matthias J. Sax commented on KAFKA-3599: [~guozhang] if I understand correctly, we remove

[jira] [Resolved] (KAFKA-3981) Possible race condition between controller cache and ZK on topic delete

[ https://issues.apache.org/jira/browse/KAFKA-3981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3981. Resolution: Not A Problem > Possible race condition between controller cache and ZK on

[jira] [Created] (KAFKA-4001) Improving join semantics in Kafka Stremas

Matthias J. Sax created KAFKA-4001: -- Summary: Improving join semantics in Kafka Stremas Key: KAFKA-4001 URL: https://issues.apache.org/jira/browse/KAFKA-4001 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-4008) Module "tools" should ne be dependent on "core"

Matthias J. Sax created KAFKA-4008: -- Summary: Module "tools" should ne be dependent on "core" Key: KAFKA-4008 URL: https://issues.apache.org/jira/browse/KAFKA-4008 Project: Kafka Issue

[jira] [Created] (KAFKA-3981) Possible race condition between controller cache and ZK on topic delete

Matthias J. Sax created KAFKA-3981: -- Summary: Possible race condition between controller cache and ZK on topic delete Key: KAFKA-3981 URL: https://issues.apache.org/jira/browse/KAFKA-3981 Project:

[jira] [Updated] (KAFKA-3185) Allow users to cleanup internal data

[ https://issues.apache.org/jira/browse/KAFKA-3185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3185: --- Status: Patch Available (was: Open) > Allow users to cleanup internal data >

[jira] [Updated] (KAFKA-3478) Finer Stream Flow Control

[ https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3478: --- Description: Today we have a event-time based flow control mechanism in order to synchronize

[jira] [Created] (KAFKA-3936) Validate user parameters as early as possible

Matthias J. Sax created KAFKA-3936: -- Summary: Validate user parameters as early as possible Key: KAFKA-3936 URL: https://issues.apache.org/jira/browse/KAFKA-3936 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-3936) Validate user parameters as early as possible

[ https://issues.apache.org/jira/browse/KAFKA-3936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3936: --- Description: Currently, parameters handed in by the user via public API, are not validated.

[jira] [Updated] (KAFKA-3880) Disallow Join Windows with size zero

[ https://issues.apache.org/jira/browse/KAFKA-3880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3880: --- Status: Patch Available (was: Open) https://github.com/apache/kafka/pull/1529 > Disallow

[jira] [Work stopped] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations

[ https://issues.apache.org/jira/browse/KAFKA-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3429 stopped by Matthias J. Sax. -- > Remove Serdes needed for repartitioning in KTable stateful operations >

[jira] [Commented] (KAFKA-4722) StreamThread should allow customization of thread prefix

[ https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849195#comment-15849195 ] Matthias J. Sax commented on KAFKA-4722: I see. I guess, we could add the {{application.id}} to

[jira] [Commented] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15848947#comment-15848947 ] Matthias J. Sax commented on KAFKA-3729: Code freeze for {{0.10.2}} was last Friday. No change to

[jira] [Commented] (KAFKA-4722) StreamThread should allow customization of thread prefix

[ https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849057#comment-15849057 ] Matthias J. Sax commented on KAFKA-4722: How does this relate to multiple KStream / KTables ? A

[jira] [Commented] (KAFKA-4722) Add application.id to StreamThread name

[ https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15850331#comment-15850331 ] Matthias J. Sax commented on KAFKA-4722: Thanks for the hint. Removing the duplicate app-Id from

[jira] [Created] (KAFKA-4732) Unstable test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegion[1]

Matthias J. Sax created KAFKA-4732: -- Summary: Unstable test: KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegion[1] Key: KAFKA-4732 URL: https://issues.apache.org/jira/browse/KAFKA-4732

[jira] [Created] (KAFKA-4731) Add event-based session windows

Matthias J. Sax created KAFKA-4731: -- Summary: Add event-based session windows Key: KAFKA-4731 URL: https://issues.apache.org/jira/browse/KAFKA-4731 Project: Kafka Issue Type: New Feature

[jira] [Updated] (KAFKA-3856) Cleanup Kafka Streams builder API

[ https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3856: --- Summary: Cleanup Kafka Streams builder API (was: Move inner classes accessible only

[jira] [Updated] (KAFKA-3856) Move inner classes accessible only functions in TopologyBuilder out of public APIs

[ https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3856: --- Description:

[jira] [Created] (KAFKA-4733) Improve Streams Reset Tool console output

Matthias J. Sax created KAFKA-4733: -- Summary: Improve Streams Reset Tool console output Key: KAFKA-4733 URL: https://issues.apache.org/jira/browse/KAFKA-4733 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-4720) Add KStream.peek(ForeachAction<K,V>)

[ https://issues.apache.org/jira/browse/KAFKA-4720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4720: --- Labels: needs-kip (was: ) > Add KStream.peek(ForeachAction) >

[jira] [Commented] (KAFKA-3543) Allow a variant of transform() which can emit multiple values

[ https://issues.apache.org/jira/browse/KAFKA-3543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15847802#comment-15847802 ] Matthias J. Sax commented on KAFKA-3543: [~gfodor] I close this as duplicate. Nevertheless one

[jira] [Resolved] (KAFKA-3543) Allow a variant of transform() which can emit multiple values

[ https://issues.apache.org/jira/browse/KAFKA-3543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3543. Resolution: Duplicate > Allow a variant of transform() which can emit multiple values >

[jira] [Created] (KAFKA-4718) Revisit DSL partitioning assumption for KStream source topics

Matthias J. Sax created KAFKA-4718: -- Summary: Revisit DSL partitioning assumption for KStream source topics Key: KAFKA-4718 URL: https://issues.apache.org/jira/browse/KAFKA-4718 Project: Kafka

[jira] (KAFKA-4317) RocksDB checkpoint files lost on kill -9

[ https://issues.apache.org/jira/browse/KAFKA-4317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4317: --- Labels: architecture needs-kip user-experience (was: architecture user-experience) >

[jira] [Commented] (KAFKA-4731) Add event-based session windows

[ https://issues.apache.org/jira/browse/KAFKA-4731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855287#comment-15855287 ] Matthias J. Sax commented on KAFKA-4731: Feel free to take it. I don't see any conflict with the

[jira] [Commented] (KAFKA-4738) Remove generic type of class ClientState

[ https://issues.apache.org/jira/browse/KAFKA-4738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15856683#comment-15856683 ] Matthias J. Sax commented on KAFKA-4738: Maybe. But we should have a new JIRA for this case. It's

[jira] [Updated] (KAFKA-4721) KafkaStreams (and possibly others) should inherit Closeable

[ https://issues.apache.org/jira/browse/KAFKA-4721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4721: --- Labels: needs-kip (was: ) > KafkaStreams (and possibly others) should inherit Closeable >

[jira] [Created] (KAFKA-4742) ResetTool does not commit offsets correclty

Matthias J. Sax created KAFKA-4742: -- Summary: ResetTool does not commit offsets correclty Key: KAFKA-4742 URL: https://issues.apache.org/jira/browse/KAFKA-4742 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-4697) Simplify Streams Reset Tool

[ https://issues.apache.org/jira/browse/KAFKA-4697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4697: --- Affects Version/s: 0.10.2.0 > Simplify Streams Reset Tool > --- > >

[jira] [Updated] (KAFKA-4317) RocksDB checkpoint files lost on kill -9

[ https://issues.apache.org/jira/browse/KAFKA-4317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4317: --- Description: Right now, the checkpoint files for logged RocksDB stores are written during a

[jira] [Created] (KAFKA-4738) Remove generic type of class ClientState

Matthias J. Sax created KAFKA-4738: -- Summary: Remove generic type of class ClientState Key: KAFKA-4738 URL: https://issues.apache.org/jira/browse/KAFKA-4738 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast

[ https://issues.apache.org/jira/browse/KAFKA-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15854436#comment-15854436 ] Matthias J. Sax commented on KAFKA-4564: With new client compatibility in {{0.10.2}} we did add

[jira] [Assigned] (KAFKA-4743) Add a tool to Reset Consumer Group Offsets

[ https://issues.apache.org/jira/browse/KAFKA-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4743: -- Assignee: Matthias J. Sax > Add a tool to Reset Consumer Group Offsets >

[jira] [Updated] (KAFKA-4743) Add a tool to Reset Consumer Group Offsets

[ https://issues.apache.org/jira/browse/KAFKA-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4743: --- Labels: kip (was: ) > Add a tool to Reset Consumer Group Offsets >

[jira] [Assigned] (KAFKA-4743) Add a tool to Reset Consumer Group Offsets

[ https://issues.apache.org/jira/browse/KAFKA-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4743: -- Assignee: (was: Matthias J. Sax) > Add a tool to Reset Consumer Group Offsets >

[jira] [Commented] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast

[ https://issues.apache.org/jira/browse/KAFKA-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15857198#comment-15857198 ] Matthias J. Sax commented on KAFKA-4564: [~guozhang] Can we close this ? > When the destination

[jira] [Commented] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast

[ https://issues.apache.org/jira/browse/KAFKA-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15857193#comment-15857193 ] Matthias J. Sax commented on KAFKA-4564: [~gwenshap] You can configure it via `request.timeout.ms`

[jira] [Updated] (KAFKA-4722) Add application.id to StreamThread name

[ https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4722: --- Summary: Add application.id to StreamThread name (was: StreamThread should allow

[jira] [Updated] (KAFKA-4722) Add application.id to StreamThread name

[ https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4722: --- Priority: Minor (was: Major) > Add application.id to StreamThread name >

[jira] [Updated] (KAFKA-4722) Add application.id to StreamThread name

[ https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4722: --- Description: StreamThread currently sets its name thusly: {code} super("StreamThread-" +

[jira] [Updated] (KAFKA-4722) Add application.id to StreamThread name

[ https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4722: --- Description: StreamThread currently sets its name thusly: {code} super("StreamThread-" +

[jira] [Updated] (KAFKA-4722) Add application.id to StreamThread name

[ https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4722: --- Issue Type: Improvement (was: New Feature) > Add application.id to StreamThread name >

[jira] [Updated] (KAFKA-4722) Add application.id to StreamThread name

[ https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4722: --- Description: StreamThread currently sets its name thusly: {code} super("StreamThread-" +

[jira] [Updated] (KAFKA-4722) Add application.id to StreamThread name

[ https://issues.apache.org/jira/browse/KAFKA-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4722: --- Labels: beginner easyfix newbie (was: ) > Add application.id to StreamThread name >

[jira] [Commented] (KAFKA-3455) Connect custom processors with the streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-3455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15847718#comment-15847718 ] Matthias J. Sax commented on KAFKA-3455: Just discovering this. I would close as "not a problem".

[jira] [Resolved] (KAFKA-4612) Simple Kafka Streams app causes "ClassCastException: java.lang.String cannot be cast to [B"

[ https://issues.apache.org/jira/browse/KAFKA-4612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4612. Resolution: Not A Problem > Simple Kafka Streams app causes "ClassCastException:

[jira] [Updated] (KAFKA-4327) Move Reset Tool from core to streams

[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4327: --- Description: This is a follow up on https://issues.apache.org/jira/browse/KAFKA-4008

[jira] [Commented] (KAFKA-4113) Allow KTable bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833891#comment-15833891 ] Matthias J. Sax commented on KAFKA-4113: [~mitch-seymour] see

[jira] [Commented] (KAFKA-4144) Allow per stream/table timestamp extractor

[ https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833899#comment-15833899 ] Matthias J. Sax commented on KAFKA-4144: Some of my thoughts: 1. I don't think, we should have a

[jira] [Commented] (KAFKA-4304) Extend Interactive Queries for return latest update timestamp per key

[ https://issues.apache.org/jira/browse/KAFKA-4304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833900#comment-15833900 ] Matthias J. Sax commented on KAFKA-4304: [~jeyhunkarimov] I am not sure what you mean by {{top-k}}

[jira] [Updated] (KAFKA-4613) Treat null-key records the same way for joins and aggreations

[ https://issues.apache.org/jira/browse/KAFKA-4613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4613: --- Status: Patch Available (was: Open) > Treat null-key records the same way for joins and

[jira] [Commented] (KAFKA-4144) Allow per stream/table timestamp extractor

[ https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833933#comment-15833933 ] Matthias J. Sax commented on KAFKA-4144: About #2: I guess, the question is what "dynamic" means.

[jira] [Commented] (KAFKA-4144) Allow per stream/table timestamp extractor

[ https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15836638#comment-15836638 ] Matthias J. Sax commented on KAFKA-4144: [~jeyhunkarimov] I don't understand this: "the

[jira] [Updated] (KAFKA-3429) Remove Serdes needed for repartitioning in KTable stateful operations

[ https://issues.apache.org/jira/browse/KAFKA-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3429: --- Fix Version/s: (was: 0.10.2.0) > Remove Serdes needed for repartitioning in KTable

[jira] [Updated] (KAFKA-4327) Move Reset Tool from core to streams

[ https://issues.apache.org/jira/browse/KAFKA-4327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4327: --- Description: This is a follow up on https://issues.apache.org/jira/browse/KAFKA-4008

[jira] [Commented] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15838744#comment-15838744 ] Matthias J. Sax commented on KAFKA-4691: I see. Understood now. Seems to be a fair change. But I

[jira] [Commented] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15838896#comment-15838896 ] Matthias J. Sax commented on KAFKA-4691: You should now have permission to assign to yourself. I

[jira] [Commented] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15838245#comment-15838245 ] Matthias J. Sax commented on KAFKA-4691: I am not sure, if we can fix this soon. The problem is,

[jira] [Created] (KAFKA-4706) Unify StreamsKafkaClient instances

Matthias J. Sax created KAFKA-4706: -- Summary: Unify StreamsKafkaClient instances Key: KAFKA-4706 URL: https://issues.apache.org/jira/browse/KAFKA-4706 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-4631) Refresh consumer metadata more frequently for unknown subscribed topics

[ https://issues.apache.org/jira/browse/KAFKA-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15838408#comment-15838408 ] Matthias J. Sax commented on KAFKA-4631: Yes. KAFKA-4633 did fix the critical problem. This is

[jira] [Commented] (KAFKA-4222) Transient failure in QueryableStateIntegrationTest.queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15838318#comment-15838318 ] Matthias J. Sax commented on KAFKA-4222: We merged couple of bug fixes the last two weeks and the

[jira] [Resolved] (KAFKA-4222) Transient failure in QueryableStateIntegrationTest.queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4222. Resolution: Fixed > Transient failure in QueryableStateIntegrationTest.queryOnRebalance >

[jira] [Commented] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15838558#comment-15838558 ] Matthias J. Sax commented on KAFKA-4691: Sorry for not being precise enough. For {{KafkaProducer}}

[jira] [Comment Edited] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15838558#comment-15838558 ] Matthias J. Sax edited comment on KAFKA-4691 at 1/25/17 8:55 PM: - Sorry

  1   2   3   4   5   6   7   8   9   10   >