[jira] [Created] (KAFKA-7274) Incorrect subject credential used in inter-broker communication

TAO XIAO created KAFKA-7274: --- Summary: Incorrect subject credential used in inter-broker communication Key: KAFKA-7274 URL: https://issues.apache.org/jira/browse/KAFKA-7274 Project: Kafka Issue

[jira] [Commented] (KAFKA-6751) Make max.connections.per.ip.overrides a dynamic config

[ https://issues.apache.org/jira/browse/KAFKA-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16575419#comment-16575419 ] ASF GitHub Bot commented on KAFKA-6751: --- hachikuji closed pull request #5334: KAFKA-6751: Support

[jira] [Resolved] (KAFKA-6751) Make max.connections.per.ip.overrides a dynamic config

[ https://issues.apache.org/jira/browse/KAFKA-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6751. Resolution: Fixed > Make max.connections.per.ip.overrides a dynamic config >

[jira] [Updated] (KAFKA-7270) Add latest releases to streams_upgrade_test.py

[ https://issues.apache.org/jira/browse/KAFKA-7270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7270: --- Description: namely, 2.0, 1.1.1, 1.0.2, 0.11.3, 0.10.2.2 Note that the relevant older

[jira] [Updated] (KAFKA-7270) Add latest releases to streams_upgrade_test.py

[ https://issues.apache.org/jira/browse/KAFKA-7270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7270: --- Affects Version/s: 0.10.2.2 0.11.0.3 1.0.2

[jira] [Updated] (KAFKA-7272) Fix ignored test in streams_upgrade_test.py: test_simple_upgrade_downgrade

[ https://issues.apache.org/jira/browse/KAFKA-7272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7272: --- Component/s: system tests > Fix ignored test in streams_upgrade_test.py:

[jira] [Updated] (KAFKA-7270) Add latest releases to streams_upgrade_test.py

[ https://issues.apache.org/jira/browse/KAFKA-7270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7270: --- Component/s: system tests > Add latest releases to streams_upgrade_test.py >

[jira] [Updated] (KAFKA-7271) Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_brokers

[ https://issues.apache.org/jira/browse/KAFKA-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7271: --- Component/s: system tests > Fix ignored test in streams_upgrade_test.py:

[jira] [Created] (KAFKA-7273) Converters should have access to headers.

Jeremy Custenborder created KAFKA-7273: -- Summary: Converters should have access to headers. Key: KAFKA-7273 URL: https://issues.apache.org/jira/browse/KAFKA-7273 Project: Kafka Issue

[jira] [Created] (KAFKA-7272) Fix ignored test in streams_upgrade_test.py: test_simple_upgrade_downgrade

John Roesler created KAFKA-7272: --- Summary: Fix ignored test in streams_upgrade_test.py: test_simple_upgrade_downgrade Key: KAFKA-7272 URL: https://issues.apache.org/jira/browse/KAFKA-7272 Project:

[jira] [Created] (KAFKA-7271) Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_brokers

John Roesler created KAFKA-7271: --- Summary: Fix ignored test in streams_upgrade_test.py: test_upgrade_downgrade_brokers Key: KAFKA-7271 URL: https://issues.apache.org/jira/browse/KAFKA-7271 Project:

[jira] [Created] (KAFKA-7270) Add latest releases to streams_upgrade_test.py

John Roesler created KAFKA-7270: --- Summary: Add latest releases to streams_upgrade_test.py Key: KAFKA-7270 URL: https://issues.apache.org/jira/browse/KAFKA-7270 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-7269) KStream.merge is not documented

[ https://issues.apache.org/jira/browse/KAFKA-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7269: --- Component/s: documentation > KStream.merge is not documented >

[jira] [Updated] (KAFKA-7269) KStream.merge is not documented

[ https://issues.apache.org/jira/browse/KAFKA-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7269: --- Labels: beginner newbie (was: ) > KStream.merge is not documented >

[jira] [Updated] (KAFKA-7269) KStream.merge is not documented

[ https://issues.apache.org/jira/browse/KAFKA-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7269: Affects Version/s: 1.0.0 1.0.1 1.0.2

[jira] [Updated] (KAFKA-7269) KStream.merge is not documented

[ https://issues.apache.org/jira/browse/KAFKA-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7269: Component/s: streams > KStream.merge is not documented > --- > >

[jira] [Created] (KAFKA-7269) KStream.merge is not documented

John Roesler created KAFKA-7269: --- Summary: KStream.merge is not documented Key: KAFKA-7269 URL: https://issues.apache.org/jira/browse/KAFKA-7269 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-6211) PartitionAssignmentState is protected whereas KafkaConsumerGroupService.describeGroup() returns PartitionAssignmentState Object

[ https://issues.apache.org/jira/browse/KAFKA-6211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6211. -- Resolution: Won't Fix Closing this in favour of AdminClient API.   > PartitionAssignmentState is

[jira] [Resolved] (KAFKA-6095) Error when displaying LAG information consumer partitions that use zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-6095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6095. -- Resolution: Auto Closed Closing as scala consumer related code/tools are removed from 2.0 release.

[jira] [Resolved] (KAFKA-6432) Lookup indices may cause unnecessary page fault

[ https://issues.apache.org/jira/browse/KAFKA-6432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6432. -- Resolution: Fixed Fix Version/s: 2.1.0 > Lookup indices may cause unnecessary page fault >

[jira] [Commented] (KAFKA-7015) Enhance RecordCollectorImpl exceptions with more context information

[ https://issues.apache.org/jira/browse/KAFKA-7015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16575212#comment-16575212 ] John Roesler commented on KAFKA-7015: - It's probably good to avoid displaying the values in error

[jira] [Commented] (KAFKA-7250) Kafka-Streams-Scala DSL transform shares transformer instance

[ https://issues.apache.org/jira/browse/KAFKA-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16575146#comment-16575146 ] ASF GitHub Bot commented on KAFKA-7250: --- guozhangwang closed pull request #5481: KAFKA-7250: switch

[jira] [Commented] (KAFKA-7232) Allow kafka-topics.sh to take brokerid as parameter to show partitions associated with it

[ https://issues.apache.org/jira/browse/KAFKA-7232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16575122#comment-16575122 ] Ratish Ravindran commented on KAFKA-7232: - [~huxi_2b] Yes, I have created KIP-350 which is under

[jira] [Updated] (KAFKA-7267) KafkaStreams Scala DSL process method should accept a ProcessorSupplier

[ https://issues.apache.org/jira/browse/KAFKA-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7267: --- Labels: scala (was: ) > KafkaStreams Scala DSL process method should accept a

[jira] [Updated] (KAFKA-7267) KafkaStreams Scala DSL process method should accept a ProcessorSupplier

[ https://issues.apache.org/jira/browse/KAFKA-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7267: --- Component/s: streams > KafkaStreams Scala DSL process method should accept a

[jira] [Updated] (KAFKA-7267) KafkaStreams Scala DSL process method should accept a ProcessorSupplier

[ https://issues.apache.org/jira/browse/KAFKA-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7267: --- Affects Version/s: 2.0.0 > KafkaStreams Scala DSL process method should accept a

[jira] [Created] (KAFKA-7268) Review Handling Crypto Rules and update ECCN page if needed

Henri Yandell created KAFKA-7268: Summary: Review Handling Crypto Rules and update ECCN page if needed Key: KAFKA-7268 URL: https://issues.apache.org/jira/browse/KAFKA-7268 Project: Kafka

[jira] [Commented] (KAFKA-7250) Kafka-Streams-Scala DSL transform shares transformer instance

[ https://issues.apache.org/jira/browse/KAFKA-7250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574974#comment-16574974 ] John Roesler commented on KAFKA-7250: - I've created [https://github.com/apache/kafka/pull/5481] to

[jira] [Created] (KAFKA-7267) KafkaStreams Scala DSL process method should accept a ProcessorSupplier

John Roesler created KAFKA-7267: --- Summary: KafkaStreams Scala DSL process method should accept a ProcessorSupplier Key: KAFKA-7267 URL: https://issues.apache.org/jira/browse/KAFKA-7267 Project: Kafka

[jira] [Updated] (KAFKA-7266) Fix MetricsTest test flakiness

[ https://issues.apache.org/jira/browse/KAFKA-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7266: --- Description: The test `kafka.api.MetricsTest.testMetrics` has been failing

[jira] [Commented] (KAFKA-1182) Topic not created if number of live brokers less than # replicas

[ https://issues.apache.org/jira/browse/KAFKA-1182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574920#comment-16574920 ] Simon Cooper commented on KAFKA-1182: - This continues to be a serious problem for us, 4 1/2 years

[jira] [Commented] (KAFKA-7266) Fix MetricsTest test flakiness

[ https://issues.apache.org/jira/browse/KAFKA-7266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574803#comment-16574803 ] ASF GitHub Bot commented on KAFKA-7266: --- stanislavkozlovski opened a new pull request #5485:

[jira] [Created] (KAFKA-7266) Fix MetricsTest test flakiness

Stanislav Kozlovski created KAFKA-7266: -- Summary: Fix MetricsTest test flakiness Key: KAFKA-7266 URL: https://issues.apache.org/jira/browse/KAFKA-7266 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-7265) Broker and consumer metrics topic names are reported differently

[ https://issues.apache.org/jira/browse/KAFKA-7265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mathias Kub updated KAFKA-7265: --- Description: Hi, I noticed that the *topic* attribute value of

[jira] [Created] (KAFKA-7265) Broker and consumer metrics topic names are reported differently

Mathias Kub created KAFKA-7265: -- Summary: Broker and consumer metrics topic names are reported differently Key: KAFKA-7265 URL: https://issues.apache.org/jira/browse/KAFKA-7265 Project: Kafka

[jira] [Commented] (KAFKA-6763) Consider using direct byte buffers in SslTransportLayer

[ https://issues.apache.org/jira/browse/KAFKA-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574742#comment-16574742 ] Leonardo Freitas Gomes commented on KAFKA-6763: --- Hi [~ijuma], The idea here is to replace

[jira] [Assigned] (KAFKA-7160) Add check for group ID length

[ https://issues.apache.org/jira/browse/KAFKA-7160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sayan Biswas reassigned KAFKA-7160: --- Assignee: (was: Sayan Biswas) > Add check for group ID length >

[jira] [Commented] (KAFKA-7261) Request and response total metrics record bytes instead of request count

[ https://issues.apache.org/jira/browse/KAFKA-7261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574696#comment-16574696 ] ASF GitHub Bot commented on KAFKA-7261: --- rajinisivaram opened a new pull request #5484: KAFKA-7261:

[jira] [Commented] (KAFKA-7134) KafkaLog4jAppender - Appender exceptions are propagated to caller

[ https://issues.apache.org/jira/browse/KAFKA-7134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574622#comment-16574622 ] Andras Katona commented on KAFKA-7134: -- My pull request's review/acceptance is a bit stuck, let me

[jira] [Commented] (KAFKA-7232) Allow kafka-topics.sh to take brokerid as parameter to show partitions associated with it

[ https://issues.apache.org/jira/browse/KAFKA-7232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574571#comment-16574571 ] huxihx commented on KAFKA-7232: --- This needs a KIP, right? > Allow kafka-topics.sh to take brokerid as

[jira] [Commented] (KAFKA-7262) Ability to support heterogeneous storage in Kafka

[ https://issues.apache.org/jira/browse/KAFKA-7262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574483#comment-16574483 ] Yechao Chen commented on KAFKA-7262: may be can like hdfs heterogeneous storage, hdd or ssd  disk

[jira] [Commented] (KAFKA-7262) Ability to support heterogeneous storage in Kafka

[ https://issues.apache.org/jira/browse/KAFKA-7262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574467#comment-16574467 ] huxihx commented on KAFKA-7262: --- [~fangbin] That might deserve a new KIP that have `TopicCommand` support

[jira] [Commented] (KAFKA-7241) Reassignment partitiona to non existent broker

[ https://issues.apache.org/jira/browse/KAFKA-7241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574331#comment-16574331 ] huxihx commented on KAFKA-7241: --- Did you try to run with `--verify` before doing reassigning. This should