[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&focusedCommentId=16749562#comment-16749562 ] ASF GitHub Bot commented on KAFKA-3522: --- mjsax commented on pull request #6186: KAF

[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&focusedCommentId=16749494#comment-16749494 ] zwangbo commented on KAFKA-7848: I add more detail log at attachment. We can focus on tes

[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 retry

[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&focusedCommentId=16749401#comment-16749401 ] huxihx commented on KAFKA-7848: --- Did you move the leader to a different broker and change i

[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 Ty

[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&focusedCommentId=16749318#comment-16749318 ] Guozhang Wang commented on KAFKA-7803: -- Generally speaking changing topic-configs on

[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&focusedCommentId=16749277#comment-16749277 ] Dhruvil Shah commented on KAFKA-7045: - Unassigning as I don't have time to work on th

[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 do

[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&focusedCommentId=16749243#comment-16749243 ] Guozhang Wang commented on KAFKA-7850: -- Ack. Let's wait for Filipe to complete 6474

[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&focusedCommentId=16749236#comment-16749236 ] Matthias J. Sax commented on KAFKA-7851: \cc [~kkonstantine] for tracking. > Con

[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&focusedCommentId=16749235#comment-16749235 ] Matthias J. Sax commented on KAFKA-7850: Seems Filipe is still interested in reso

[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&focusedCommentId=16749234#comment-16749234 ] Matthias J. Sax commented on KAFKA-6474: Thanks [~h314to]. SGTM. \cc [~guozhang]

[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&focusedCommentId=16749226#comment-16749226 ] Matthias J. Sax commented on KAFKA-7775: Thanks for reporting this. It's a know i

[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 con

[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 con

[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 top

[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&focusedCommentId=16749214#comment-16749214 ] Matthias J. Sax commented on KAFKA-: This is an interesting request. Note, th

[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 high

[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&focusedCommentId=16749208#comment-16749208 ] Matthias J. Sax commented on KAFKA-7803: [~guozhang] Do you think this is feasibl

[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&focusedCommentId=16749171#comment-16749171 ] Del Bao commented on KAFKA-7432: A real-world scenario to back this use case:  An event

[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&focusedCommentId=16749129#comment-16749129 ] Filipe Agapito commented on KAFKA-6474: --- Hi [~mjsax]. Thanks for pinging me. Sorry,

[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&focusedCommentId=16749102#comment-16749102 ] Christian Richter commented on KAFKA-7851: -- [~mjsax] Thank you, yes that is exac

[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&focusedCommentId=16749043#comment-16749043 ] Adem Efe Gencer commented on KAFKA-7854: *Relevant Cruise Control Issue*: [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 IncrementalAlte

[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: https://issues.apache.org/jira/browse/KAFKA-

[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 - F

[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 Project:

[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&focusedCommentId=16748947#comment-16748947 ] Matthias J. Sax commented on KAFKA-6474: [~h314to] We are thinking about resolvin

[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&focusedCommentId=16748945#comment-16748945 ] Matthias J. Sax commented on KAFKA-7850: Works for me. \cc [~h314to] I left a co

[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&focusedCommentId=16748943#comment-16748943 ] Matthias J. Sax commented on KAFKA-7852: Is this a duplicate of https://issues.ap

[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&focusedCommentId=16748942#comment-16748942 ] Matthias J. Sax commented on KAFKA-7851: [~cri] Your might be interested in this

[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: https://issues.apache.org/jira/browse/KAFKA

[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&focusedCommentId=16748925#comment-16748925 ] Guozhang Wang commented on KAFKA-7850: -- Filipe has made several changes to remove KS

[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&focusedCommentId=16748916#comment-16748916 ] Ryanne Dolan commented on KAFKA-7815: - Pull Request > SourceTask should expose ACK'd

[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 constructor

[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 Proje

[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: Improvemen

[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: I

[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 ot