[jira] [Commented] (KAFKA-7578) Kafka streams: add possibility to choose multiple output topics

[ https://issues.apache.org/jira/browse/KAFKA-7578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855347#comment-16855347 ] Matthias J. Sax commented on KAFKA-7578: [~tdanylchuk] Was wondering about this ticket. You

[jira] [Commented] (KAFKA-8433) Give the opportunity to use serializers and deserializers with IntegrationTestUtils

[ https://issues.apache.org/jira/browse/KAFKA-8433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855305#comment-16855305 ] Matthias J. Sax commented on KAFKA-8433: A [~callaertanthony] – does using the public

[jira] [Updated] (KAFKA-8446) Kafka Streams restoration crashes with NPE when the record value is null

[ https://issues.apache.org/jira/browse/KAFKA-8446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8446: --- Fix Version/s: 2.3.0 > Kafka Streams restoration crashes with NPE when the record value is

[jira] [Updated] (KAFKA-8155) Update Streams system tests for 2.2.0 and 2.1.1 releases

[ https://issues.apache.org/jira/browse/KAFKA-8155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8155: --- Priority: Blocker (was: Major) > Update Streams system tests for 2.2.0 and 2.1.1 releases >

[jira] [Commented] (KAFKA-8155) Update Streams system tests for 2.2.0 and 2.1.1 releases

[ https://issues.apache.org/jira/browse/KAFKA-8155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855291#comment-16855291 ] ASF GitHub Bot commented on KAFKA-8155: --- mjsax commented on pull request #6597: KAFKA-8155: Add

[jira] [Commented] (KAFKA-8331) Add system test for enabling static membership on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855284#comment-16855284 ] ASF GitHub Bot commented on KAFKA-8331: --- abbccdda commented on pull request #6877: KAFKA-8331:

[jira] [Commented] (KAFKA-8404) Authorization header is not passed in Connect when forwarding REST requests

[ https://issues.apache.org/jira/browse/KAFKA-8404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855238#comment-16855238 ] Randall Hauch commented on KAFKA-8404: -- Merged back to `2.3`, but still working on merging back to

[jira] [Updated] (KAFKA-8404) Authorization header is not passed in Connect when forwarding REST requests

[ https://issues.apache.org/jira/browse/KAFKA-8404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8404: - Fix Version/s: 2.2.2 2.1.2 2.0.2 > Authorization header is

[jira] [Commented] (KAFKA-8404) Authorization header is not passed in Connect when forwarding REST requests

[ https://issues.apache.org/jira/browse/KAFKA-8404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855231#comment-16855231 ] ASF GitHub Bot commented on KAFKA-8404: --- rhauch commented on pull request #6791: KAFKA-8404: Add

[jira] [Commented] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

[ https://issues.apache.org/jira/browse/KAFKA-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855227#comment-16855227 ] ASF GitHub Bot commented on KAFKA-7315: --- londoncalling commented on pull request #6875: KAFKA-7315

[jira] [Commented] (KAFKA-7315) Streams serialization docs contain a broken link for Avro

[ https://issues.apache.org/jira/browse/KAFKA-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855226#comment-16855226 ] ASF GitHub Bot commented on KAFKA-7315: --- londoncalling commented on pull request #212: KAFKA-7315

[jira] [Created] (KAFKA-8477) Cannot consume and request metadata for __consumer_offsets topic in Kafka 2.2

Mike Mintz created KAFKA-8477: - Summary: Cannot consume and request metadata for __consumer_offsets topic in Kafka 2.2 Key: KAFKA-8477 URL: https://issues.apache.org/jira/browse/KAFKA-8477 Project: Kafka

[jira] [Assigned] (KAFKA-8404) Authorization header is not passed in Connect when forwarding REST requests

[ https://issues.apache.org/jira/browse/KAFKA-8404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reassigned KAFKA-8404: Assignee: Robert Yokota https://github.com/apache/kafka/pull/6791 > Authorization header

[jira] [Resolved] (KAFKA-8473) Adjust Connect system tests for incremental cooperative rebalancing and enable them for both eager and incremental cooperative rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8473. -- Resolution: Fixed Reviewer: Randall Hauch > Adjust Connect system tests for incremental

[jira] [Commented] (KAFKA-8473) Adjust Connect system tests for incremental cooperative rebalancing and enable them for both eager and incremental cooperative rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855093#comment-16855093 ] ASF GitHub Bot commented on KAFKA-8473: --- rhauch commented on pull request #6872: KAFKA-8473: Adjust

[jira] [Updated] (KAFKA-8272) Changed(De)Serializer does not forward configure() call

[ https://issues.apache.org/jira/browse/KAFKA-8272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8272: --- Fix Version/s: (was: 2.3.0) > Changed(De)Serializer does not forward configure() call >

[jira] [Commented] (KAFKA-8272) Changed(De)Serializer does not forward configure() call

[ https://issues.apache.org/jira/browse/KAFKA-8272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855090#comment-16855090 ] Matthias J. Sax commented on KAFKA-8272: No. Removed fixed version. We can set if after the PR is

[jira] [Commented] (KAFKA-6819) Refactor build-in StreamsMetrics internal implementations

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

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

[ https://issues.apache.org/jira/browse/KAFKA-8383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8383. Resolution: Fixed > Write integration test for electLeaders >

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

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

[jira] [Updated] (KAFKA-8476) Kafka 2.2.1 distribution contains JAX-RS API twice

[ https://issues.apache.org/jira/browse/KAFKA-8476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gunnar Morling updated KAFKA-8476: -- Description: In kafka_2.12-2.2.1.tgz there is both javax.ws.rs-api-2.1.jar and

[jira] [Updated] (KAFKA-8476) Kafka 2.2.1 distribution contains JAX-RS API twice

[ https://issues.apache.org/jira/browse/KAFKA-8476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gunnar Morling updated KAFKA-8476: -- Priority: Minor (was: Major) > Kafka 2.2.1 distribution contains JAX-RS API twice >

[jira] [Created] (KAFKA-8476) Kafka 2.2.1 distribution contains JAX-RS API twice

Gunnar Morling created KAFKA-8476: - Summary: Kafka 2.2.1 distribution contains JAX-RS API twice Key: KAFKA-8476 URL: https://issues.apache.org/jira/browse/KAFKA-8476 Project: Kafka Issue

[jira] [Commented] (KAFKA-8473) Adjust Connect system tests for incremental cooperative rebalancing and enable them for both eager and incremental cooperative rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854910#comment-16854910 ] ASF GitHub Bot commented on KAFKA-8473: --- kkonstantine commented on pull request #6872: KAFKA-8473:

[jira] [Resolved] (KAFKA-8475) Temporarily restore SslFactory.sslContext() helper

[ https://issues.apache.org/jira/browse/KAFKA-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-8475. Resolution: Fixed Fix Version/s: 2.3 > Temporarily restore SslFactory.sslContext()

[jira] [Created] (KAFKA-8475) Temporarily restore SslFactory.sslContext() helper

Colin P. McCabe created KAFKA-8475: -- Summary: Temporarily restore SslFactory.sslContext() helper Key: KAFKA-8475 URL: https://issues.apache.org/jira/browse/KAFKA-8475 Project: Kafka Issue

[jira] [Updated] (KAFKA-8473) Adjust Connect system tests for incremental cooperative rebalancing and enable them for both eager and incremental cooperative rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8473: - Priority: Critical (was: Major) > Adjust Connect system tests for incremental cooperative

[jira] [Commented] (KAFKA-8474) Improve configuration layout on website

[ https://issues.apache.org/jira/browse/KAFKA-8474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854838#comment-16854838 ] ASF GitHub Bot commented on KAFKA-8474: --- mimaison commented on pull request #211: KAFKA-8474:

[jira] [Commented] (KAFKA-8474) Improve configuration layout on website

[ https://issues.apache.org/jira/browse/KAFKA-8474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854837#comment-16854837 ] ASF GitHub Bot commented on KAFKA-8474: --- mimaison commented on pull request #6870: KAFKA-8474: Use

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

[ https://issues.apache.org/jira/browse/KAFKA-8398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justine Olshan reassigned KAFKA-8398: - Assignee: (was: Justine Olshan) > NPE when unmapping files after moving log

[jira] [Commented] (KAFKA-4893) async topic deletion conflicts with max topic length

[ https://issues.apache.org/jira/browse/KAFKA-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854816#comment-16854816 ] ASF GitHub Bot commented on KAFKA-4893: --- cmccabe commented on pull request #6869: KAFKA-4893: limit

[jira] [Resolved] (KAFKA-8469) Named Suppress Operator Needs to increment Name Counter

[ https://issues.apache.org/jira/browse/KAFKA-8469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8469. Resolution: Not A Problem > Named Suppress Operator Needs to increment Name Counter >

[jira] [Commented] (KAFKA-8469) Named Suppress Operator Needs to increment Name Counter

[ https://issues.apache.org/jira/browse/KAFKA-8469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854808#comment-16854808 ] ASF GitHub Bot commented on KAFKA-8469: --- bbejeck commented on pull request #6868: KAFKA-8469: Fix

[jira] [Updated] (KAFKA-8474) Improve configuration layout on website

[ https://issues.apache.org/jira/browse/KAFKA-8474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison updated KAFKA-8474: -- Description: The description of configurations on the website are really hard to read due to

[jira] [Created] (KAFKA-8474) Improve configuration layout on website

Mickael Maison created KAFKA-8474: - Summary: Improve configuration layout on website Key: KAFKA-8474 URL: https://issues.apache.org/jira/browse/KAFKA-8474 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8473) Adjust Connect system tests for incremental cooperative rebalancing and enable them for both eager and incremental cooperative rebalancing

Konstantine Karantasis created KAFKA-8473: - Summary: Adjust Connect system tests for incremental cooperative rebalancing and enable them for both eager and incremental cooperative rebalancing Key: KAFKA-8473

[jira] [Updated] (KAFKA-8426) KIP 421 Bug: ConfigProvider configs param inconsistent with KIP-297

[ https://issues.apache.org/jira/browse/KAFKA-8426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-8426: -- Priority: Blocker (was: Minor) > KIP 421 Bug: ConfigProvider configs param inconsistent with

[jira] [Commented] (KAFKA-7995) Augment singleton protocol type to list for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-7995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854774#comment-16854774 ] Sagar Rao commented on KAFKA-7995: -- [~bchen225242] I see that there's an error called

[jira] [Updated] (KAFKA-8418) Connect System tests are not waiting for REST resources to be registered

[ https://issues.apache.org/jira/browse/KAFKA-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-8418: --- Priority: Blocker (was: Critical) > Connect System tests are not waiting for REST resources

[jira] [Updated] (KAFKA-8418) Connect System tests are not waiting for REST resources to be registered

[ https://issues.apache.org/jira/browse/KAFKA-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-8418: --- Fix Version/s: 2.3 > Connect System tests are not waiting for REST resources to be

[jira] [Updated] (KAFKA-8429) Consumer should handle offset change while OffsetForLeaderEpoch is inflight

[ https://issues.apache.org/jira/browse/KAFKA-8429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-8429: --- Priority: Blocker (was: Major) > Consumer should handle offset change while

[jira] [Commented] (KAFKA-8449) Restart task on reconfiguration under incremental cooperative rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854760#comment-16854760 ] ASF GitHub Bot commented on KAFKA-8449: --- rhauch commented on pull request #6850: KAFKA-8449:

[jira] [Updated] (KAFKA-8187) State store record loss across multiple reassignments when using standby tasks

[ https://issues.apache.org/jira/browse/KAFKA-8187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-8187: --- Priority: Blocker (was: Major) > State store record loss across multiple reassignments when

[jira] [Created] (KAFKA-8472) Use composition for better isolation of fetcher logic

Jason Gustafson created KAFKA-8472: -- Summary: Use composition for better isolation of fetcher logic Key: KAFKA-8472 URL: https://issues.apache.org/jira/browse/KAFKA-8472 Project: Kafka

[jira] [Updated] (KAFKA-7703) KafkaConsumer.position may return a wrong offset after "seekToEnd" is called

[ https://issues.apache.org/jira/browse/KAFKA-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-7703: --- Priority: Blocker (was: Major) > KafkaConsumer.position may return a wrong offset after

[jira] [Commented] (KAFKA-5810) Improve authentication logging on the broker-side

[ https://issues.apache.org/jira/browse/KAFKA-5810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854739#comment-16854739 ] In Park commented on KAFKA-5810: Hi [~rsivaram], I would like to ask some clarification regarding this

[jira] [Created] (KAFKA-8471) Replace control requests/responses with automated protocol

Ismael Juma created KAFKA-8471: -- Summary: Replace control requests/responses with automated protocol Key: KAFKA-8471 URL: https://issues.apache.org/jira/browse/KAFKA-8471 Project: Kafka Issue

[jira] [Created] (KAFKA-8470) State change logs should not be in TRACE level

Stanislav Kozlovski created KAFKA-8470: -- Summary: State change logs should not be in TRACE level Key: KAFKA-8470 URL: https://issues.apache.org/jira/browse/KAFKA-8470 Project: Kafka

[jira] [Commented] (KAFKA-8469) Named Suppress Operator Needs to increment Name Counter

[ https://issues.apache.org/jira/browse/KAFKA-8469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854720#comment-16854720 ] John Roesler commented on KAFKA-8469: - Hey [~bbejeck], sorry for the confusion, but this ticket is

[jira] [Commented] (KAFKA-8404) Authorization header is not passed in Connect when forwarding REST requests

[ https://issues.apache.org/jira/browse/KAFKA-8404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854712#comment-16854712 ] Ismael Juma commented on KAFKA-8404: [~rhauch] Is this an actual blocker for the 2.3 release? >

[jira] [Commented] (KAFKA-8272) Changed(De)Serializer does not forward configure() call

[ https://issues.apache.org/jira/browse/KAFKA-8272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854713#comment-16854713 ] Ismael Juma commented on KAFKA-8272: [~mjsax] Are you still targeting 2.3.0? Only blockers should be

[jira] [Commented] (KAFKA-8469) Named Suppress Operator Needs to increment Name Counter

[ https://issues.apache.org/jira/browse/KAFKA-8469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854691#comment-16854691 ] ASF GitHub Bot commented on KAFKA-8469: --- bbejeck commented on pull request #6868: KAFKA-8469: Fix

[jira] [Commented] (KAFKA-8469) Named Suppress Operator Needs to increment Name Counter

[ https://issues.apache.org/jira/browse/KAFKA-8469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854682#comment-16854682 ] ASF GitHub Bot commented on KAFKA-8469: --- bbejeck commented on pull request #6863: KAFKA-8469: Fix

[jira] [Created] (KAFKA-8469) Named Suppress Operator Needs to increment Name Counter

Bill Bejeck created KAFKA-8469: -- Summary: Named Suppress Operator Needs to increment Name Counter Key: KAFKA-8469 URL: https://issues.apache.org/jira/browse/KAFKA-8469 Project: Kafka Issue

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

[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854633#comment-16854633 ] Pavel Savov commented on KAFKA-8367: [~guozhang] Sure, please see the following gist: 

[jira] [Commented] (KAFKA-8426) KIP 421 Bug: ConfigProvider configs param inconsistent with KIP-297

[ https://issues.apache.org/jira/browse/KAFKA-8426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854503#comment-16854503 ] ASF GitHub Bot commented on KAFKA-8426: --- rajinisivaram commented on pull request #6750: KAFKA-8426;

[jira] [Commented] (KAFKA-8425) KIP 421 Bug: Modifying Immutable Originals Map results in Java exception

[ https://issues.apache.org/jira/browse/KAFKA-8425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854494#comment-16854494 ] ASF GitHub Bot commented on KAFKA-8425: --- rajinisivaram commented on pull request #6795: KAFKA-8425:

[jira] [Created] (KAFKA-8468) AdminClient.deleteTopics doesn't wait until topic is deleted

Gabor Somogyi created KAFKA-8468: Summary: AdminClient.deleteTopics doesn't wait until topic is deleted Key: KAFKA-8468 URL: https://issues.apache.org/jira/browse/KAFKA-8468 Project: Kafka

[jira] [Created] (KAFKA-8467) Trogdor - Add option to delete topic in RoundTripWorker

Stanislav Kozlovski created KAFKA-8467: -- Summary: Trogdor - Add option to delete topic in RoundTripWorker Key: KAFKA-8467 URL: https://issues.apache.org/jira/browse/KAFKA-8467 Project: Kafka

[jira] [Created] (KAFKA-8466) Remove 'jackson-module-scala' dependency (and replace it with some code)

Dejan Stojadinović created KAFKA-8466: - Summary: Remove 'jackson-module-scala' dependency (and replace it with some code) Key: KAFKA-8466 URL: https://issues.apache.org/jira/browse/KAFKA-8466

[jira] [Commented] (KAFKA-8328) Kafka smooth expansion

[ https://issues.apache.org/jira/browse/KAFKA-8328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854411#comment-16854411 ] ChenLin commented on KAFKA-8328: Thank you for your attention, I will submit KIP as soon as possible. >

[jira] [Updated] (KAFKA-8465) Copying strategy for the topic dimension

[ https://issues.apache.org/jira/browse/KAFKA-8465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChenLin updated KAFKA-8465: --- Attachment: replication__strategy_for_the_topic_dimension.patch > Copying strategy for the topic dimension >

[jira] [Updated] (KAFKA-8465) Copying strategy for the topic dimension

[ https://issues.apache.org/jira/browse/KAFKA-8465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChenLin updated KAFKA-8465: --- Attachment: (was: Copying_strategy_for_the_topic_dimension.patch) > Copying strategy for the topic

[jira] [Commented] (KAFKA-8465) Copying strategy for the topic dimension

[ https://issues.apache.org/jira/browse/KAFKA-8465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854394#comment-16854394 ] ASF GitHub Bot commented on KAFKA-8465: --- lordcheng10 commented on pull request #6866:

[jira] [Commented] (KAFKA-8465) Copying strategy for the topic dimension

[ https://issues.apache.org/jira/browse/KAFKA-8465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16854362#comment-16854362 ] ASF GitHub Bot commented on KAFKA-8465: --- lordcheng10 commented on pull request #6862: