[jira] [Commented] (KAFKA-3917) Some __consumer_offsets replicas grow way too big

2019-04-13 Thread Boquan Tang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16816874#comment-16816874 ] Boquan Tang commented on KAFKA-3917: We have met the same issue with our 2.0.1 cluste

[jira] [Created] (KAFKA-8228) Exactly once semantics break during server restart for kafka-streams application

2019-04-13 Thread Boquan Tang (JIRA)
Boquan Tang created KAFKA-8228: -- Summary: Exactly once semantics break during server restart for kafka-streams application Key: KAFKA-8228 URL: https://issues.apache.org/jira/browse/KAFKA-8228 Project: K

[jira] [Updated] (KAFKA-8228) Exactly once semantics break during server restart for kafka-streams application

2019-04-13 Thread Boquan Tang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boquan Tang updated KAFKA-8228: --- Description: We are using 2.2.0 for kafka-streams client and 2.0.1 for server. We have a simple kafk

[jira] [Updated] (KAFKA-8228) Exactly once semantics break during server restart for kafka-streams application

2019-04-13 Thread Boquan Tang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boquan Tang updated KAFKA-8228: --- Description: We are using 2.2.0 for kafka-streams client and 2.0.1 for server. We have a simple kafk

[jira] [Commented] (KAFKA-8228) Exactly once semantics break during server restart for kafka-streams application

2019-04-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817075#comment-16817075 ] Matthias J. Sax commented on KAFKA-8228: You Stream side understanding is correct

[jira] [Assigned] (KAFKA-8052) Intermittent INVALID_FETCH_SESSION_EPOCH error on FETCH request

2019-04-13 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-8052: - Assignee: Rajini Sivaram > Intermittent INVALID_FETCH_SESSION_EPOCH error on FETCH reque

[jira] [Commented] (KAFKA-8213) KStreams interactive query documentation typo

2019-04-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817107#comment-16817107 ] ASF GitHub Bot commented on KAFKA-8213: --- mjsax commented on pull request #201: KAFK

[jira] [Commented] (KAFKA-8213) KStreams interactive query documentation typo

2019-04-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817109#comment-16817109 ] ASF GitHub Bot commented on KAFKA-8213: --- mjsax commented on pull request #6574: KAF

[jira] [Resolved] (KAFKA-8213) KStreams interactive query documentation typo

2019-04-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8213. Resolution: Fixed > KStreams interactive query documentation typo > ---

[jira] [Commented] (KAFKA-8212) KStreams documentation Maven artifact table is cut off

2019-04-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817111#comment-16817111 ] ASF GitHub Bot commented on KAFKA-8212: --- mjsax commented on pull request #200: KAFK

[jira] [Commented] (KAFKA-8212) KStreams documentation Maven artifact table is cut off

2019-04-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817112#comment-16817112 ] ASF GitHub Bot commented on KAFKA-8212: --- mjsax commented on pull request #6576: KAF

[jira] [Resolved] (KAFKA-8212) KStreams documentation Maven artifact table is cut off

2019-04-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8212. Resolution: Fixed > KStreams documentation Maven artifact table is cut off > --

[jira] [Commented] (KAFKA-8209) Wrong link for KStreams DSL in Core Concepts doc

2019-04-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817114#comment-16817114 ] ASF GitHub Bot commented on KAFKA-8209: --- bbejeck commented on pull request #6564: K

[jira] [Commented] (KAFKA-8209) Wrong link for KStreams DSL in Core Concepts doc

2019-04-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817125#comment-16817125 ] ASF GitHub Bot commented on KAFKA-8209: --- bbejeck commented on pull request #198: KA

[jira] [Commented] (KAFKA-8210) Missing link for KStreams in Streams DSL docs

2019-04-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817127#comment-16817127 ] ASF GitHub Bot commented on KAFKA-8210: --- bbejeck commented on pull request #6573: K

[jira] [Commented] (KAFKA-8204) Streams may flush state stores in the incorrect order

2019-04-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817128#comment-16817128 ] Matthias J. Sax commented on KAFKA-8204: Nice find! Thanks for the details! > St

[jira] [Commented] (KAFKA-8210) Missing link for KStreams in Streams DSL docs

2019-04-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817129#comment-16817129 ] ASF GitHub Bot commented on KAFKA-8210: --- bbejeck commented on pull request #199: KA

[jira] [Assigned] (KAFKA-8227) Missing Links in Duality of Streams and Tables section

2019-04-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8227: -- Assignee: Victoria Bialas > Missing Links in Duality of Streams and Tables section > -

[jira] [Commented] (KAFKA-8208) Broken link for out-of-order data in KStreams Core Concepts doc

2019-04-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817130#comment-16817130 ] ASF GitHub Bot commented on KAFKA-8208: --- bbejeck commented on pull request #197: KA

[jira] [Commented] (KAFKA-8208) Broken link for out-of-order data in KStreams Core Concepts doc

2019-04-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817131#comment-16817131 ] ASF GitHub Bot commented on KAFKA-8208: --- bbejeck commented on pull request #6572: K

[jira] [Resolved] (KAFKA-8208) Broken link for out-of-order data in KStreams Core Concepts doc

2019-04-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8208. Resolution: Fixed Fix Version/s: 2.3.0 > Broken link for out-of-order data in KStreams Core

[jira] [Updated] (KAFKA-8210) Missing link for KStreams in Streams DSL docs

2019-04-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8210: --- Fix Version/s: 2.3.0 > Missing link for KStreams in Streams DSL docs > --

[jira] [Resolved] (KAFKA-8210) Missing link for KStreams in Streams DSL docs

2019-04-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8210. Resolution: Fixed > Missing link for KStreams in Streams DSL docs > ---

[jira] [Updated] (KAFKA-8209) Wrong link for KStreams DSL in Core Concepts doc

2019-04-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8209: --- Fix Version/s: 2.3.0 > Wrong link for KStreams DSL in Core Concepts doc > ---

[jira] [Resolved] (KAFKA-8209) Wrong link for KStreams DSL in Core Concepts doc

2019-04-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8209. Resolution: Fixed > Wrong link for KStreams DSL in Core Concepts doc >

[jira] [Commented] (KAFKA-8207) StickyPartitionAssignor for KStream

2019-04-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817133#comment-16817133 ] Matthias J. Sax commented on KAFKA-8207: Thanks for following up! {quote}StreamPa

[jira] [Commented] (KAFKA-8228) Exactly once semantics break during server restart for kafka-streams application

2019-04-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817135#comment-16817135 ] Matthias J. Sax commented on KAFKA-8228: I just discovered KAFKA-7866 – could thi

[jira] [Created] (KAFKA-8229) Connect Sink Task updates nextCommit when commitRequest is true

2019-04-13 Thread Scott Reynolds (JIRA)
Scott Reynolds created KAFKA-8229: - Summary: Connect Sink Task updates nextCommit when commitRequest is true Key: KAFKA-8229 URL: https://issues.apache.org/jira/browse/KAFKA-8229 Project: Kafka

[jira] [Commented] (KAFKA-8229) Connect Sink Task updates nextCommit when commitRequest is true

2019-04-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817137#comment-16817137 ] ASF GitHub Bot commented on KAFKA-8229: --- sdreynolds commented on pull request #6579

[jira] [Created] (KAFKA-8230) Add static membership support in librd consumer client

2019-04-13 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8230: -- Summary: Add static membership support in librd consumer client Key: KAFKA-8230 URL: https://issues.apache.org/jira/browse/KAFKA-8230 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-8230) Add static membership support in librd consumer client

2019-04-13 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817148#comment-16817148 ] Ismael Juma commented on KAFKA-8230: That's a good idea, but we should track it via

[jira] [Updated] (KAFKA-8228) Exactly once semantics break during server restart for kafka-streams application

2019-04-13 Thread Boquan Tang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boquan Tang updated KAFKA-8228: --- Description: We are using 2.2.0 for kafka-streams client and 2.0.1 for server. We have a simple kafk

[jira] [Commented] (KAFKA-8228) Exactly once semantics break during server restart for kafka-streams application

2019-04-13 Thread Boquan Tang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817153#comment-16817153 ] Boquan Tang commented on KAFKA-8228: Thanks [~mjsax] for looking into this, yes I mea

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2019-04-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16817160#comment-16817160 ] Matthias J. Sax commented on KAFKA-7965: One more:  [https://builds.apache.org/jo

[jira] [Updated] (KAFKA-8231) Expansion of ConnectClusterState interface

2019-04-13 Thread Chris Egerton (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton updated KAFKA-8231: - Component/s: KafkaConnect > Expansion of ConnectClusterState interface >

[jira] [Created] (KAFKA-8231) Expansion of ConnectClusterState interface

2019-04-13 Thread Chris Egerton (JIRA)
Chris Egerton created KAFKA-8231: Summary: Expansion of ConnectClusterState interface Key: KAFKA-8231 URL: https://issues.apache.org/jira/browse/KAFKA-8231 Project: Kafka Issue Type: Improvem