[jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format

2019-01-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749562#comment-16749562 ] ASF GitHub Bot commented on KAFKA-3522: --- mjsax commented on pull request #6186: KAFKA-3522: Add

[jira] [Commented] (KAFKA-7848) Idempotence producer keep retry on OutOfOrderSequenceException

2019-01-22 Thread zwangbo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749494#comment-16749494 ] zwangbo commented on KAFKA-7848: I add more detail log at attachment. We can focus on test-88 partition.

[jira] [Updated] (KAFKA-7848) Idempotence producer keep retry on OutOfOrderSequenceException

2019-01-22 Thread zwangbo (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zwangbo updated KAFKA-7848: --- Attachment: server-partition88.log producer-partition88.log > Idempotence producer keep

[jira] [Assigned] (KAFKA-7466) Implement KIP-339: Create a new IncrementalAlterConfigs API

2019-01-22 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-7466: Assignee: Manikumar > Implement KIP-339: Create a new IncrementalAlterConfigs API >

[jira] [Commented] (KAFKA-7848) Idempotence producer keep retry on OutOfOrderSequenceException

2019-01-22 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749401#comment-16749401 ] huxihx commented on KAFKA-7848: --- Did you move the leader to a different broker and change it back soon? A

[jira] [Created] (KAFKA-7858) Replace JoinGroup request/response with automated protocol

2019-01-22 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-7858: -- Summary: Replace JoinGroup request/response with automated protocol Key: KAFKA-7858 URL: https://issues.apache.org/jira/browse/KAFKA-7858 Project: Kafka Issue

[jira] [Created] (KAFKA-7859) Replace LeaveGroup request/response with automated protocol

2019-01-22 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-7859: -- Summary: Replace LeaveGroup request/response with automated protocol Key: KAFKA-7859 URL: https://issues.apache.org/jira/browse/KAFKA-7859 Project: Kafka Issue

[jira] [Commented] (KAFKA-7803) Kafka Streams internal topics config is not updated when the code is changed

2019-01-22 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749318#comment-16749318 ] Guozhang Wang commented on KAFKA-7803: -- Generally speaking changing topic-configs on the fly should

[jira] [Commented] (KAFKA-7045) Consumer may not be able to consume all messages when down-conversion is required

2019-01-22 Thread Dhruvil Shah (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749277#comment-16749277 ] Dhruvil Shah commented on KAFKA-7045: - Unassigning as I don't have time to work on this at the

[jira] [Assigned] (KAFKA-7045) Consumer may not be able to consume all messages when down-conversion is required

2019-01-22 Thread Dhruvil Shah (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruvil Shah reassigned KAFKA-7045: --- Assignee: (was: Dhruvil Shah) > Consumer may not be able to consume all messages when

[jira] [Commented] (KAFKA-7850) Remove deprecated KStreamTestDriver

2019-01-22 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749243#comment-16749243 ] Guozhang Wang commented on KAFKA-7850: -- Ack. Let's wait for Filipe to complete 6474 then :)

[jira] [Commented] (KAFKA-7851) Continue data streaming while rebalancing

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749236#comment-16749236 ] Matthias J. Sax commented on KAFKA-7851: \cc [~kkonstantine] for tracking. > Continue data

[jira] [Commented] (KAFKA-7850) Remove deprecated KStreamTestDriver

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749235#comment-16749235 ] Matthias J. Sax commented on KAFKA-7850: Seems Filipe is still interested in resolving 6474

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749234#comment-16749234 ] Matthias J. Sax commented on KAFKA-6474: Thanks [~h314to]. SGTM. \cc [~guozhang] and [~Yohan123]

[jira] [Commented] (KAFKA-7775) [KStream] remove topic prefix from consumer configuration to resolve unnecessary warning

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749226#comment-16749226 ] Matthias J. Sax commented on KAFKA-7775: Thanks for reporting this. It's a know issue, however

[jira] [Updated] (KAFKA-7775) [KStream] remove topic prefix from consumer configuration to resolve unnecessary warning

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7775: --- Component/s: clients admin > [KStream] remove topic prefix from consumer

[jira] [Updated] (KAFKA-7775) [KStream] remove topic prefix from consumer configuration to resolve unnecessary warning

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7775: --- Priority: Minor (was: Major) > [KStream] remove topic prefix from consumer configuration to

[jira] [Updated] (KAFKA-7775) [KStream] remove topic prefix from consumer configuration to resolve unnecessary warning

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7775: --- Labels: needs-kip newbie++ (was: newbie++) > [KStream] remove topic prefix from consumer

[jira] [Updated] (KAFKA-7775) [KStream] remove topic prefix from consumer configuration to resolve unnecessary warning

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7775: --- External issue URL: (was: https://github.com/apache/kafka/pull/6067) > [KStream] remove

[jira] [Commented] (KAFKA-7777) Decouple topic serdes from materialized serdes

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749214#comment-16749214 ] Matthias J. Sax commented on KAFKA-: This is an interesting request. Note, that in state

[jira] [Updated] (KAFKA-7777) Decouple topic serdes from materialized serdes

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-: --- Labels: needs-kip (was: ) > Decouple topic serdes from materialized serdes >

[jira] [Updated] (KAFKA-7777) Decouple topic serdes from materialized serdes

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-: --- Priority: Minor (was: Trivial) > Decouple topic serdes from materialized serdes >

[jira] [Assigned] (KAFKA-7821) Streams: default cache size can lose session windows in high-throughput deployment

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7821: -- Assignee: Guozhang Wang > Streams: default cache size can lose session windows in

[jira] [Commented] (KAFKA-7803) Kafka Streams internal topics config is not updated when the code is changed

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749208#comment-16749208 ] Matthias J. Sax commented on KAFKA-7803: [~guozhang] Do you think this is feasible? I think it's

[jira] [Commented] (KAFKA-7432) API Method on Kafka Streams for processing chunks/batches of data

2019-01-22 Thread Del Bao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749171#comment-16749171 ] Del Bao commented on KAFKA-7432: A real-world scenario to back this use case:  An event logging topic

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

2019-01-22 Thread Filipe Agapito (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749129#comment-16749129 ] Filipe Agapito commented on KAFKA-6474: --- Hi [~mjsax]. Thanks for pinging me. Sorry, I haven't been

[jira] [Commented] (KAFKA-7851) Continue data streaming while rebalancing

2019-01-22 Thread Christian Richter (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749102#comment-16749102 ] Christian Richter commented on KAFKA-7851: -- [~mjsax] Thank you, yes that is exactly what I was

[jira] [Commented] (KAFKA-7854) Behavior change in controller picking up partition reassignment tasks since 1.1.0

2019-01-22 Thread Adem Efe Gencer (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16749043#comment-16749043 ] Adem Efe Gencer commented on KAFKA-7854: *Relevant Cruise Control Issue*:

[jira] [Assigned] (KAFKA-7466) Implement KIP-339: Create a new IncrementalAlterConfigs API

2019-01-22 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe reassigned KAFKA-7466: -- Assignee: (was: Colin P. McCabe) > Implement KIP-339: Create a new

[jira] [Created] (KAFKA-7857) Add AbstractCoordinatorConfig class to consolidate consumer coordinator configs between Consumer and Connect

2019-01-22 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-7857: -- Summary: Add AbstractCoordinatorConfig class to consolidate consumer coordinator configs between Consumer and Connect Key: KAFKA-7857 URL:

[jira] [Updated] (KAFKA-7856) Cryptographic Issues by Insufficient Entropy

2019-01-22 Thread Victor Sartori (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Sartori updated KAFKA-7856: -- Description: We pass the kakfa client in security analisys ans this scans reports: CWE-331 -

[jira] [Created] (KAFKA-7856) Cryptographic Issues by Insufficient Entropy

2019-01-22 Thread Victor Sartori (JIRA)
Victor Sartori created KAFKA-7856: - Summary: Cryptographic Issues by Insufficient Entropy Key: KAFKA-7856 URL: https://issues.apache.org/jira/browse/KAFKA-7856 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-7855) Kafka Streams Maven Archetype quickstart fails to compile out of the box

2019-01-22 Thread Michael Drogalis (JIRA)
Michael Drogalis created KAFKA-7855: --- Summary: Kafka Streams Maven Archetype quickstart fails to compile out of the box Key: KAFKA-7855 URL: https://issues.apache.org/jira/browse/KAFKA-7855

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748947#comment-16748947 ] Matthias J. Sax commented on KAFKA-6474: [~h314to] We are thinking about resolving this ticket

[jira] [Commented] (KAFKA-7850) Remove deprecated KStreamTestDriver

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748945#comment-16748945 ] Matthias J. Sax commented on KAFKA-7850: Works for me. \cc [~h314to] I left a comment on the

[jira] [Commented] (KAFKA-7852) Add public version of EmbeddedKafkaCluster

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748943#comment-16748943 ] Matthias J. Sax commented on KAFKA-7852: Is this a duplicate of

[jira] [Commented] (KAFKA-7851) Continue data streaming while rebalancing

2019-01-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748942#comment-16748942 ] Matthias J. Sax commented on KAFKA-7851: [~cri] Your might be interested in this proposal:

[jira] [Created] (KAFKA-7854) Behavior change in controller picking up partition reassignment tasks since 1.1.0

2019-01-22 Thread Zhanxiang (Patrick) Huang (JIRA)
Zhanxiang (Patrick) Huang created KAFKA-7854: Summary: Behavior change in controller picking up partition reassignment tasks since 1.1.0 Key: KAFKA-7854 URL:

[jira] [Commented] (KAFKA-7850) Remove deprecated KStreamTestDriver

2019-01-22 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748925#comment-16748925 ] Guozhang Wang commented on KAFKA-7850: -- Filipe has made several changes to remove KStreamTestDriver

[jira] [Commented] (KAFKA-7815) SourceTask should expose ACK'd offsets, metadata

2019-01-22 Thread Ryanne Dolan (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748916#comment-16748916 ] Ryanne Dolan commented on KAFKA-7815: - Pull Request > SourceTask should expose ACK'd offsets,

[jira] [Assigned] (KAFKA-7853) Refactor ConsumerCoordinator/AbstractCoordinator to reduce constructor parameter list

2019-01-22 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-7853: -- Assignee: Boyang Chen > Refactor ConsumerCoordinator/AbstractCoordinator to reduce

[jira] [Created] (KAFKA-7853) Refactor ConsumerCoordinator/AbstractCoordinator to reduce constructor parameter list

2019-01-22 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-7853: -- Summary: Refactor ConsumerCoordinator/AbstractCoordinator to reduce constructor parameter list Key: KAFKA-7853 URL: https://issues.apache.org/jira/browse/KAFKA-7853

[jira] [Created] (KAFKA-7852) Add public version of EmbeddedKafkaCluster

2019-01-22 Thread John Roesler (JIRA)
John Roesler created KAFKA-7852: --- Summary: Add public version of EmbeddedKafkaCluster Key: KAFKA-7852 URL: https://issues.apache.org/jira/browse/KAFKA-7852 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-7851) Continue data streaming while rebalancing

2019-01-22 Thread Christian Richter (JIRA)
Christian Richter created KAFKA-7851: Summary: Continue data streaming while rebalancing Key: KAFKA-7851 URL: https://issues.apache.org/jira/browse/KAFKA-7851 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-6777) Wrong reaction on Out Of Memory situation

2019-01-22 Thread Seweryn Habdank-Wojewodzki (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki resolved KAFKA-6777. --- Resolution: Won't Fix Last comment is accepted. We have to prepare