[jira] [Updated] (KAFKA-8611) Add KStream#repartition operation

2019-07-09 Thread Levani Kokhreidze (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze updated KAFKA-8611: - Summary: Add KStream#repartition operation (was: Make topic optional when using through(

[jira] [Created] (KAFKA-8641) Invalid value ogg_kafka_test_key for configuration value.deserializer: Class ogg_kafka_test_key could not be found.

2019-07-09 Thread chen qiang (JIRA)
chen qiang created KAFKA-8641: - Summary: Invalid value ogg_kafka_test_key for configuration value.deserializer: Class ogg_kafka_test_key could not be found. Key: KAFKA-8641 URL: https://issues.apache.org/jira/browse/K

[jira] [Commented] (KAFKA-8641) Invalid value ogg_kafka_test_key for configuration value.deserializer: Class ogg_kafka_test_key could not be found.

2019-07-09 Thread chen qiang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881094#comment-16881094 ] chen qiang commented on KAFKA-8641: --- 我开启了10个消费者的线程,做为初始化的线程。调用这个方法时,报错了以上的错误。请问有关于多线程消费

[jira] [Commented] (KAFKA-8633) Extra in generated documents

2019-07-09 Thread Weichu Liu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881110#comment-16881110 ] Weichu Liu commented on KAFKA-8633: --- Seems no one is responding, so I will make a PR to

[jira] [Commented] (KAFKA-8633) Extra in generated documents

2019-07-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881135#comment-16881135 ] ASF GitHub Bot commented on KAFKA-8633: --- weichuliu commented on pull request #7056:

[jira] [Updated] (KAFKA-8633) Extra in generated documents

2019-07-09 Thread Weichu Liu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weichu Liu updated KAFKA-8633: -- Description: The auto generated tables for all configurations (e.g. https://kafka.apache.org/documenta

[jira] [Updated] (KAFKA-8633) Extra in generated documents

2019-07-09 Thread Weichu Liu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weichu Liu updated KAFKA-8633: -- Description: The auto generated tables for all configurations (e.g. [https://kafka.apache.org/document

[jira] [Assigned] (KAFKA-8615) Change to track partition time breaks TimestampExtractor

2019-07-09 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-8615: -- Assignee: Sophie Blee-Goldman (was: Bill Bejeck) > Change to track partition time breaks Time

[jira] [Commented] (KAFKA-8638) Preferred Leader Blacklist (deprioritized list)

2019-07-09 Thread Jose Armando Garcia Sancio (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881421#comment-16881421 ] Jose Armando Garcia Sancio commented on KAFKA-8638: --- Hi George, Thanks

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

2019-07-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881468#comment-16881468 ] ASF GitHub Bot commented on KAFKA-: --- cmccabe commented on pull request #6771: K

[jira] [Commented] (KAFKA-8638) Preferred Leader Blacklist (deprioritized list)

2019-07-09 Thread GEORGE LI (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881480#comment-16881480 ] GEORGE LI commented on KAFKA-8638: -- Hi Jose, Because a broker can have hundreds/thousan

[jira] [Commented] (KAFKA-8638) Preferred Leader Blacklist (deprioritized list)

2019-07-09 Thread Jose Armando Garcia Sancio (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881511#comment-16881511 ] Jose Armando Garcia Sancio commented on KAFKA-8638: --- Thanks for feedbac

[jira] [Created] (KAFKA-8642) Send LeaveGroupRequest for static members when reaching `max.poll.interval.ms`

2019-07-09 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8642: -- Summary: Send LeaveGroupRequest for static members when reaching `max.poll.interval.ms` Key: KAFKA-8642 URL: https://issues.apache.org/jira/browse/KAFKA-8642 Project: Kaf

[jira] [Commented] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

2019-07-09 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881603#comment-16881603 ] Sophie Blee-Goldman commented on KAFKA-8630: Yep, that's the KIP. There was s

[jira] [Created] (KAFKA-8643) Incompatible MemberDescription constructor change

2019-07-09 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8643: -- Summary: Incompatible MemberDescription constructor change Key: KAFKA-8643 URL: https://issues.apache.org/jira/browse/KAFKA-8643 Project: Kafka Issue Type: Bug

[jira] [Assigned] (KAFKA-7788) Support null defaults in KAFKA-7609 RPC specifications

2019-07-09 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe reassigned KAFKA-7788: -- Assignee: Colin P. McCabe > Support null defaults in KAFKA-7609 RPC specifications > -

[jira] [Resolved] (KAFKA-7788) Support null defaults in KAFKA-7609 RPC specifications

2019-07-09 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-7788. Resolution: Duplicate > Support null defaults in KAFKA-7609 RPC specifications > --

[jira] [Created] (KAFKA-8644) The Kafka protocol generator should allow null defaults for bytes and array fields

2019-07-09 Thread Colin P. McCabe (JIRA)
Colin P. McCabe created KAFKA-8644: -- Summary: The Kafka protocol generator should allow null defaults for bytes and array fields Key: KAFKA-8644 URL: https://issues.apache.org/jira/browse/KAFKA-8644

[jira] [Commented] (KAFKA-8644) The Kafka protocol generator should allow null defaults for bytes and array fields

2019-07-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881611#comment-16881611 ] ASF GitHub Bot commented on KAFKA-8644: --- cmccabe commented on pull request #7059: K

[jira] [Commented] (KAFKA-8643) Incompatible MemberDescription constructor change

2019-07-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881613#comment-16881613 ] ASF GitHub Bot commented on KAFKA-8643: --- abbccdda commented on pull request #7060:

[jira] [Resolved] (KAFKA-8642) Send LeaveGroupRequest for static members when reaching `max.poll.interval.ms`

2019-07-09 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8642. Resolution: Invalid Synced with [~hachikuji], the session timeout should always be smaller than the

[jira] [Commented] (KAFKA-8640) Replace OffsetFetch request/response with automated protocol

2019-07-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881660#comment-16881660 ] ASF GitHub Bot commented on KAFKA-8640: --- abbccdda commented on pull request #7062:

[jira] [Created] (KAFKA-8645) Flakey test SaslSslAdminClientIntegrationTest#testElectUncleanLeadersAndNoop

2019-07-09 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8645: -- Summary: Flakey test SaslSslAdminClientIntegrationTest#testElectUncleanLeadersAndNoop Key: KAFKA-8645 URL: https://issues.apache.org/jira/browse/KAFKA-8645 Project: Kafka