[jira] [Created] (KAFKA-8400) Do not update follower replica state if the log read failed

2019-05-20 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-8400: -- Summary: Do not update follower replica state if the log read failed Key: KAFKA-8400 URL: https://issues.apache.org/jira/browse/KAFKA-8400 Project: Kafka

[jira] [Commented] (KAFKA-8399) Add back `internal.leave.group.on.close` config for KStreams

2019-05-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844397#comment-16844397 ] ASF GitHub Bot commented on KAFKA-8399: --- abbccdda commented on pull request #6779: KAFKA-8399:

[jira] [Created] (KAFKA-8399) Add back `internal.leave.group.on.close` config for KStreams

2019-05-20 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8399: -- Summary: Add back `internal.leave.group.on.close` config for KStreams Key: KAFKA-8399 URL: https://issues.apache.org/jira/browse/KAFKA-8399 Project: Kafka

[jira] [Comment Edited] (KAFKA-6029) Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest

2019-05-20 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844388#comment-16844388 ] Jason Gustafson edited comment on KAFKA-6029 at 5/20/19 11:36 PM: -- I

[jira] [Commented] (KAFKA-6029) Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest

2019-05-20 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844388#comment-16844388 ] Jason Gustafson commented on KAFKA-6029: I think we can actually resolve this as a unintended

[jira] [Created] (KAFKA-8398) NPE when unmapping files after moving log directories using AlterReplicaLogDirs

2019-05-20 Thread Vikas Singh (JIRA)
Vikas Singh created KAFKA-8398: -- Summary: NPE when unmapping files after moving log directories using AlterReplicaLogDirs Key: KAFKA-8398 URL: https://issues.apache.org/jira/browse/KAFKA-8398 Project:

[jira] [Created] (KAFKA-8397) Add pre-registration feature for static membership

2019-05-20 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8397: -- Summary: Add pre-registration feature for static membership Key: KAFKA-8397 URL: https://issues.apache.org/jira/browse/KAFKA-8397 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

2019-05-20 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844297#comment-16844297 ] John Roesler commented on KAFKA-8377: - Oh, it also looks like the value getter supplier returns a new

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

2019-05-20 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844290#comment-16844290 ] John Roesler commented on KAFKA-8377: - I happened to be looking at the TransformValues today for

[jira] [Commented] (KAFKA-8347) Choose next record to process by timestamp

2019-05-20 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844233#comment-16844233 ] Sophie Blee-Goldman commented on KAFKA-8347: Oh I missed the RC1 email but you're right, will

[jira] [Updated] (KAFKA-8347) Choose next record to process by timestamp

2019-05-20 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8347: --- Fix Version/s: (was: 2.2.1) 2.2.2 > Choose next record to

[jira] [Commented] (KAFKA-8265) Connect Client Config Override policy

2019-05-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844218#comment-16844218 ] ASF GitHub Bot commented on KAFKA-8265: --- rhauch commented on pull request #6755: KAFKA-8265 : Fix

[jira] [Resolved] (KAFKA-5476) Implement a system test that creates network partitions

2019-05-20 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-5476. Resolution: Duplicate > Implement a system test that creates network partitions >

[jira] [Updated] (KAFKA-8074) Create SSL keystore/truststore only once for each node in system tests

2019-05-20 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-8074: --- Fix Version/s: (was: 2.3.0) > Create SSL keystore/truststore only once for each node in

[jira] [Updated] (KAFKA-3190) KafkaProducer should not invoke callback in send()

2019-05-20 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-3190: --- Fix Version/s: (was: 2.3.0) 2.4.0 Moving to 2.4.0, since 2.3 seems

[jira] [Updated] (KAFKA-3333) Alternative Partitioner to Support "Always Round-Robin" partitioning

2019-05-20 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-: --- Fix Version/s: (was: 2.3.0) 2.4.0 Moving this out of 2.3 and into

[jira] [Resolved] (KAFKA-7921) Instable KafkaStreamsTest

2019-05-20 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-7921. Resolution: Fixed Let's re-open this if we see another failure. > Instable

[jira] [Commented] (KAFKA-7991) Add StreamsUpgradeTest for 2.2 release

2019-05-20 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844188#comment-16844188 ] Colin P. McCabe commented on KAFKA-7991: Do you still want to do this in 2.3? > Add

[jira] [Updated] (KAFKA-8385) Fix leader election RPC for all partition so that only partition that had elections are returned

2019-05-20 Thread Jose Armando Garcia Sancio (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-8385: -- Fix Version/s: (was: 2.3.0) > Fix leader election RPC for all

[jira] [Updated] (KAFKA-8384) Write integration tests for leader election command

2019-05-20 Thread Jose Armando Garcia Sancio (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-8384: -- Fix Version/s: (was: 2.3.0) > Write integration tests for leader

[jira] [Updated] (KAFKA-8383) Write integration test for electLeaders

2019-05-20 Thread Jose Armando Garcia Sancio (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-8383: -- Fix Version/s: (was: 2.3.0) > Write integration test for

[jira] [Updated] (KAFKA-8265) Connect Client Config Override policy

2019-05-20 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-8265: --- Affects Version/s: (was: 2.3.0) Fix Version/s: (was: 2.3.0) > Connect Client

[jira] [Assigned] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

2019-05-20 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe reassigned KAFKA-7500: -- Assignee: (was: Colin P. McCabe) Fix Version/s: (was: 2.3.0)

[jira] [Updated] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

2019-05-20 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-7500: --- Reviewer: (was: Colin P. McCabe) > MirrorMaker 2.0 (KIP-382) > - >

[jira] [Comment Edited] (KAFKA-8207) StickyPartitionAssignor for KStream

2019-05-20 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844168#comment-16844168 ] Boyang Chen edited comment on KAFKA-8207 at 5/20/19 6:01 PM: - Hey

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

2019-05-20 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844168#comment-16844168 ] Boyang Chen commented on KAFKA-8207: Hey [~neeraj.bhatt] thank you for your interest! Good news is

[jira] [Updated] (KAFKA-8284) Enable static membership on KStream

2019-05-20 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8284: --- Fix Version/s: 2.3.0 > Enable static membership on KStream > --- > >

[jira] [Updated] (KAFKA-8220) Avoid kicking out members through rebalance timeout

2019-05-20 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8220: --- Fix Version/s: 2.3.0 > Avoid kicking out members through rebalance timeout >

[jira] [Updated] (KAFKA-7862) Modify JoinGroup logic to incorporate group.instance.id change

2019-05-20 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-7862: --- Fix Version/s: 2.3.0 > Modify JoinGroup logic to incorporate group.instance.id change >

[jira] [Updated] (KAFKA-8225) Handle conflicting static member id

2019-05-20 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8225: --- Fix Version/s: 2.3.0 > Handle conflicting static member id > --- > >

[jira] [Resolved] (KAFKA-7992) Add a server start time metric

2019-05-20 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-7992. Resolution: Fixed Fix Version/s: 2.3.0 > Add a server start time metric >

[jira] [Resolved] (KAFKA-8316) Remove deprecated usage of Slf4jRequestLog, SslContextFactory

2019-05-20 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8316. Resolution: Fixed > Remove deprecated usage of Slf4jRequestLog, SslContextFactory >

[jira] [Commented] (KAFKA-8316) Remove deprecated usage of Slf4jRequestLog, SslContextFactory

2019-05-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844128#comment-16844128 ] ASF GitHub Bot commented on KAFKA-8316: --- hachikuji commented on pull request #6668: KAFKA-8316:

[jira] [Commented] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist

2019-05-20 Thread Muzeeb (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844109#comment-16844109 ] Muzeeb commented on KAFKA-7633: --- Which version

[jira] [Updated] (KAFKA-8364) Avoid decompression of record when validate record at server in the scene of inPlaceAssignment .

2019-05-20 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8364: - Description: We do performance testing about Kafka server in specific scenarios .We build a

[jira] [Updated] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

2019-05-20 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8377: - Labels: newbie++ (was: ) > KTable#transformValue might lead to incorrect result in joins >

[jira] [Commented] (KAFKA-8365) Protocol and consumer support for follower fetching

2019-05-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844104#comment-16844104 ] ASF GitHub Bot commented on KAFKA-8365: --- mumrah commented on pull request #6775: Minor: follow up

[jira] [Commented] (KAFKA-8396) Clean up Transformer API

2019-05-20 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844095#comment-16844095 ] Guozhang Wang commented on KAFKA-8396: -- I like the idea; About the further cleanup (TBD), note one

[jira] [Updated] (KAFKA-8396) Clean up Transformer API

2019-05-20 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8396: - Labels: needs-kip user-experience (was: needs-kip) > Clean up Transformer API >

[jira] [Updated] (KAFKA-8371) Remove ReplicaManager dependence from Partition

2019-05-20 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8371: - Labels: tech-debt (was: ) > Remove ReplicaManager dependence from Partition >

[jira] [Resolved] (KAFKA-7358) Alternative Partitioner to Support "Always Round-Robin" Selection

2019-05-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7358. Resolution: Duplicate > Alternative Partitioner to Support "Always Round-Robin" Selection

[jira] [Updated] (KAFKA-8373) Add group.instance.id field into Sync/Heartbeat/OffsetCommit protocols

2019-05-20 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8373: - Fix Version/s: 2.3.0 > Add group.instance.id field into Sync/Heartbeat/OffsetCommit protocols >

[jira] [Updated] (KAFKA-8396) Clean up Transformer API

2019-05-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8396: --- Labels: needs-kip (was: ) > Clean up Transformer API > > >

[jira] [Commented] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-05-20 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844075#comment-16844075 ] Guozhang Wang commented on KAFKA-8367: -- Could creating the {{new BloomFilter()}} in KAFKA-4850 just

[jira] [Resolved] (KAFKA-8381) SSL factory for inter-broker listener is broken

2019-05-20 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8381. --- Resolution: Fixed Reviewer: Manikumar > SSL factory for inter-broker listener is

[jira] [Created] (KAFKA-8396) Clean up Transformer API

2019-05-20 Thread John Roesler (JIRA)
John Roesler created KAFKA-8396: --- Summary: Clean up Transformer API Key: KAFKA-8396 URL: https://issues.apache.org/jira/browse/KAFKA-8396 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-8395) Add an ability to backup log segment files on truncation

2019-05-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844064#comment-16844064 ] ASF GitHub Bot commented on KAFKA-8395: --- axiak commented on pull request #6772: KAFKA-8395: Add the

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

2019-05-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844062#comment-16844062 ] Matthias J. Sax commented on KAFKA-8207: I actually just talked to [~bchen225242] – it seems that

[jira] [Created] (KAFKA-8395) Add an ability to backup log segment files on truncation

2019-05-20 Thread Michael Axiak (JIRA)
Michael Axiak created KAFKA-8395: Summary: Add an ability to backup log segment files on truncation Key: KAFKA-8395 URL: https://issues.apache.org/jira/browse/KAFKA-8395 Project: Kafka Issue

[jira] [Updated] (KAFKA-8395) Add an ability to backup log segment files on truncation

2019-05-20 Thread Michael Axiak (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Axiak updated KAFKA-8395: - Flags: Patch > Add an ability to backup log segment files on truncation >

[jira] [Resolved] (KAFKA-8376) Flaky test ClientAuthenticationFailureTest.testTransactionalProducerWithInvalidCredentials test.

2019-05-20 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8376. Resolution: Fixed > Flaky test >

[jira] [Commented] (KAFKA-8381) SSL factory for inter-broker listener is broken

2019-05-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844046#comment-16844046 ] ASF GitHub Bot commented on KAFKA-8381: --- rajinisivaram commented on pull request #6757: KAFKA-8381;

[jira] [Commented] (KAFKA-3333) Alternative Partitioner to Support "Always Round-Robin" partitioning

2019-05-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844019#comment-16844019 ] ASF GitHub Bot commented on KAFKA-: --- mmanna-sapfgl commented on pull request #6771: KAFKA-:

[jira] [Updated] (KAFKA-3333) Alternative Partitioner to Support "Always Round-Robin" partitioning

2019-05-20 Thread M. Manna (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna updated KAFKA-: Description: ** Please Look into KAFKA-7358 for the official description **   The

[jira] [Assigned] (KAFKA-3333) Alternative Partitioner to Support "Always Round-Robin" partitioning

2019-05-20 Thread M. Manna (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna reassigned KAFKA-: --- Assignee: M. Manna Fix Version/s: 2.3.0 Affects Version/s: (was: 0.10.0.0)

[jira] [Updated] (KAFKA-3333) Alternative Partitioner to Support "Always Round-Robin" assignment

2019-05-20 Thread M. Manna (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna updated KAFKA-: Summary: Alternative Partitioner to Support "Always Round-Robin" assignment (was: Client Partitioner -

[jira] [Updated] (KAFKA-3333) Alternative Partitioner to Support "Always Round-Robin" partitioning

2019-05-20 Thread M. Manna (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna updated KAFKA-: Summary: Alternative Partitioner to Support "Always Round-Robin" partitioning (was: Alternative

[jira] [Comment Edited] (KAFKA-7358) Alternative Partitioner to Support "Always Round-Robin" Selection

2019-05-20 Thread M. Manna (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16843951#comment-16843951 ] M. Manna edited comment on KAFKA-7358 at 5/20/19 2:24 PM: -- [~mjsax] Yes - looks

[jira] [Commented] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-05-20 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16843982#comment-16843982 ] Bill Bejeck commented on KAFKA-8290: cherry-picked to 2.2, 2.1 and 2.0 > Streams Not Closing Fenced

[jira] [Updated] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-05-20 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8290: --- Fix Version/s: 2.0.2 > Streams Not Closing Fenced Producer On Task Close >

[jira] [Updated] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-05-20 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8290: --- Fix Version/s: 2.2.2 2.1.2 2.3.0 > Streams Not Closing Fenced

[jira] [Commented] (KAFKA-7358) Alternative Partitioner to Support "Always Round-Robin" Selection

2019-05-20 Thread M. Manna (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16843951#comment-16843951 ] M. Manna commented on KAFKA-7358: - [~mjsax] Yes - looks like my pull request effort was not put in the

[jira] [Updated] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-05-20 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-8290: --- Affects Version/s: 2.0.0 2.1.0 2.2.0 > Streams Not

[jira] [Commented] (KAFKA-8290) Streams Not Closing Fenced Producer On Task Close

2019-05-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16843944#comment-16843944 ] ASF GitHub Bot commented on KAFKA-8290: --- bbejeck commented on pull request #6636: KAFKA-8290: Close

[jira] [Created] (KAFKA-8394) Cannot Start a build with New Gradle Version

2019-05-20 Thread M. Manna (JIRA)
M. Manna created KAFKA-8394: --- Summary: Cannot Start a build with New Gradle Version Key: KAFKA-8394 URL: https://issues.apache.org/jira/browse/KAFKA-8394 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-05-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16843739#comment-16843739 ] Matthias J. Sax commented on KAFKA-7994: I am personally not convinced, that using headers is the

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

2019-05-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16843733#comment-16843733 ] Matthias J. Sax commented on KAFKA-8207: I think that's correct. [~bchen225242] worked hard to

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

2019-05-20 Thread neeraj (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16843677#comment-16843677 ] neeraj commented on KAFKA-8207: --- [~mjsax] KIP 345 seems is not a part of 2.3 release as given in