[jira] [Commented] (KAFKA-4587) Rethink Unification of Caching with Dedupping

[ https://issues.apache.org/jira/browse/KAFKA-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069241#comment-17069241 ] Maatari commented on KAFKA-4587: Hi all, i'm note sure to follow what is the status of th

[jira] [Comment Edited] (KAFKA-6443) KTable involved in multiple joins could result in duplicate results

[ https://issues.apache.org/jira/browse/KAFKA-6443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069222#comment-17069222 ] Maatari edited comment on KAFKA-6443 at 3/28/20, 5:18 AM: -- Hi al

[jira] [Commented] (KAFKA-6443) KTable involved in multiple joins could result in duplicate results

[ https://issues.apache.org/jira/browse/KAFKA-6443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069222#comment-17069222 ] Daniel Okouya commented on KAFKA-6443: -- Hi all, is there a way to know what is the s

[jira] [Commented] (KAFKA-9770) Caching State Store does not Close Underlying State Store When Exception is Thrown During Flushing

[ https://issues.apache.org/jira/browse/KAFKA-9770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069171#comment-17069171 ] ASF GitHub Bot commented on KAFKA-9770: --- vvcephei commented on pull request #8368:

[jira] [Commented] (KAFKA-9774) Create official Docker image for Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-9774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069144#comment-17069144 ] Jordan Moore commented on KAFKA-9774: - [~rhauch] & [~kkonstantine] , lemme know your

[jira] [Updated] (KAFKA-9778) Add validateConnector functionality to the EmbeddedConnectCluster

[ https://issues.apache.org/jira/browse/KAFKA-9778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Osvath updated KAFKA-9778: - Description: A validate endpoint should be added to enables the integration testing of validatio

[jira] [Updated] (KAFKA-9779) Add version 2.5 to streams system tests

[ https://issues.apache.org/jira/browse/KAFKA-9779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9779: --- Component/s: system tests streams > Add version 2.5 to streams system tests

[jira] [Commented] (KAFKA-9779) Add version 2.5 to streams system tests

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

[jira] [Created] (KAFKA-9780) Deprecate commit records without record metadata

Mario Molina created KAFKA-9780: --- Summary: Deprecate commit records without record metadata Key: KAFKA-9780 URL: https://issues.apache.org/jira/browse/KAFKA-9780 Project: Kafka Issue Type: Impr

[jira] [Created] (KAFKA-9779) Add version 2.5 to streams system tests

Boyang Chen created KAFKA-9779: -- Summary: Add version 2.5 to streams system tests Key: KAFKA-9779 URL: https://issues.apache.org/jira/browse/KAFKA-9779 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-9778) Add validateConnector functionality to the EmbeddedConnectCluster

Daniel Osvath created KAFKA-9778: Summary: Add validateConnector functionality to the EmbeddedConnectCluster Key: KAFKA-9778 URL: https://issues.apache.org/jira/browse/KAFKA-9778 Project: Kafka

[jira] [Commented] (KAFKA-9777) Purgatory locking bug can lead to hanging transaction

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

[jira] [Updated] (KAFKA-9776) Producer should automatically downgrade TxnOffsetCommitRequest

[ https://issues.apache.org/jira/browse/KAFKA-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9776: --- Summary: Producer should automatically downgrade TxnOffsetCommitRequest (was: Producer shoul

[jira] [Updated] (KAFKA-9776) Producer should automatically downgrade TxnOffsetCommitRequest

[ https://issues.apache.org/jira/browse/KAFKA-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9776: --- Description: When using transactions with a 2.5 producer against 2.4 (or older) brokers, it

[jira] [Commented] (KAFKA-9724) Consumer wrongly ignores fetched records "since it no longer has valid position"

[ https://issues.apache.org/jira/browse/KAFKA-9724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069028#comment-17069028 ] ASF GitHub Bot commented on KAFKA-9724: --- mumrah commented on pull request #8376: KA

[jira] [Commented] (KAFKA-9776) Producer should automatically downgrade CommitTxRequest

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

[jira] [Created] (KAFKA-9777) Purgatory locking bug can lead to hanging transaction

Jason Gustafson created KAFKA-9777: -- Summary: Purgatory locking bug can lead to hanging transaction Key: KAFKA-9777 URL: https://issues.apache.org/jira/browse/KAFKA-9777 Project: Kafka Issue

[jira] [Assigned] (KAFKA-9776) Producer should automatically downgrade CommitTxRequest

[ https://issues.apache.org/jira/browse/KAFKA-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9776: -- Assignee: Boyang Chen > Producer should automatically downgrade CommitTxRequest >

[jira] [Created] (KAFKA-9776) Producer should automatically downgrade CommitTxRequest

Matthias J. Sax created KAFKA-9776: -- Summary: Producer should automatically downgrade CommitTxRequest Key: KAFKA-9776 URL: https://issues.apache.org/jira/browse/KAFKA-9776 Project: Kafka Iss

[jira] [Resolved] (KAFKA-9771) Inter-worker SSL is broken for keystores with multiple certificates

[ https://issues.apache.org/jira/browse/KAFKA-9771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-9771. --- Resolution: Fixed The fix was merged in `trunk` and the `2.5` release branch

[jira] [Updated] (KAFKA-9771) Inter-worker SSL is broken for keystores with multiple certificates

[ https://issues.apache.org/jira/browse/KAFKA-9771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-9771: -- Fix Version/s: (was: 2.5.0) > Inter-worker SSL is broken for keystores with

[jira] [Updated] (KAFKA-9771) Inter-worker SSL is broken for keystores with multiple certificates

[ https://issues.apache.org/jira/browse/KAFKA-9771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-9771: -- Affects Version/s: (was: 2.5.0) > Inter-worker SSL is broken for keystores

[jira] [Updated] (KAFKA-9771) Inter-worker SSL is broken for keystores with multiple certificates

[ https://issues.apache.org/jira/browse/KAFKA-9771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-9771: -- Fix Version/s: 2.5.0 > Inter-worker SSL is broken for keystores with multiple c

[jira] [Commented] (KAFKA-9771) Inter-worker SSL is broken for keystores with multiple certificates

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

[jira] [Commented] (KAFKA-9770) Caching State Store does not Close Underlying State Store When Exception is Thrown During Flushing

[ https://issues.apache.org/jira/browse/KAFKA-9770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068820#comment-17068820 ] ASF GitHub Bot commented on KAFKA-9770: --- cadonna commented on pull request #8368: K

[jira] [Commented] (KAFKA-9770) Caching State Store does not Close Underlying State Store When Exception is Thrown During Flushing

[ https://issues.apache.org/jira/browse/KAFKA-9770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068819#comment-17068819 ] ASF GitHub Bot commented on KAFKA-9770: --- vvcephei commented on pull request #8368:

[jira] [Updated] (KAFKA-9770) Caching State Store does not Close Underlying State Store When Exception is Thrown During Flushing

[ https://issues.apache.org/jira/browse/KAFKA-9770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9770: - Affects Version/s: (was: 2.5.0) 2.0.0 > Caching State Store does not C

[jira] [Updated] (KAFKA-9770) Caching State Store does not Close Underlying State Store When Exception is Thrown During Flushing

[ https://issues.apache.org/jira/browse/KAFKA-9770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9770: - Affects Version/s: (was: 2.6.0) 2.5.0 > Caching State Store does not C

[jira] [Commented] (KAFKA-9775) IllegalFormatConversionException from kafka-consumer-perf-test.sh

[ https://issues.apache.org/jira/browse/KAFKA-9775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068581#comment-17068581 ] ASF GitHub Bot commented on KAFKA-9775: --- tombentley commented on pull request #8373

[jira] [Created] (KAFKA-9775) IllegalFormatConversionException from kafka-consumer-perf-test.sh

Tom Bentley created KAFKA-9775: -- Summary: IllegalFormatConversionException from kafka-consumer-perf-test.sh Key: KAFKA-9775 URL: https://issues.apache.org/jira/browse/KAFKA-9775 Project: Kafka

[jira] [Commented] (KAFKA-9773) Option combination "[bootstrap-server],[config]" can't be used with option "[alter]"

[ https://issues.apache.org/jira/browse/KAFKA-9773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068530#comment-17068530 ] Luke Chen commented on KAFKA-9773: -- Meanwhile, I'll work on this issue. > Option combin

[jira] [Commented] (KAFKA-1206) allow Kafka to start from a resource negotiator system

[ https://issues.apache.org/jira/browse/KAFKA-1206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068526#comment-17068526 ] Jordan Moore commented on KAFKA-1206: - How relevant is this in light of Mesos or Kube

[jira] [Commented] (KAFKA-10) Kafka deployment on EC2 should be WHIRR based, instead of current contrib/deploy code based solution

[ https://issues.apache.org/jira/browse/KAFKA-10?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068525#comment-17068525 ] Jordan Moore commented on KAFKA-10: --- This should be closed. Whirr is in the Apache Attic.

[jira] [Commented] (KAFKA-5306) Official init.d scripts

[ https://issues.apache.org/jira/browse/KAFKA-5306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068521#comment-17068521 ] Jordan Moore commented on KAFKA-5306: - I feel like SystemD won out the battle for the

[jira] [Comment Edited] (KAFKA-9773) Option combination "[bootstrap-server],[config]" can't be used with option "[alter]"

[ https://issues.apache.org/jira/browse/KAFKA-9773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068518#comment-17068518 ] Luke Chen edited comment on KAFKA-9773 at 3/27/20, 10:21 AM: -

[jira] [Commented] (KAFKA-9774) Create official Docker image for Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-9774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068519#comment-17068519 ] Jordan Moore commented on KAFKA-9774: - Happy to take this on. And already working on

[jira] [Commented] (KAFKA-9773) Option combination "[bootstrap-server],[config]" can't be used with option "[alter]"

[ https://issues.apache.org/jira/browse/KAFKA-9773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068518#comment-17068518 ] Luke Chen commented on KAFKA-9773: -- Please use kafka-config.sh --alter instead. Ex: k{{

[jira] [Created] (KAFKA-9774) Create official Docker image for Kafka Connect

Jordan Moore created KAFKA-9774: --- Summary: Create official Docker image for Kafka Connect Key: KAFKA-9774 URL: https://issues.apache.org/jira/browse/KAFKA-9774 Project: Kafka Issue Type: Task

[jira] [Updated] (KAFKA-9773) Option combination "[bootstrap-server],[config]" can't be used with option "[alter]"

[ https://issues.apache.org/jira/browse/KAFKA-9773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] startjava updated KAFKA-9773: - Issue Type: Test (was: Task) > Option combination "[bootstrap-server],[config]" can't be used with optio

[jira] [Created] (KAFKA-9773) Option combination "[bootstrap-server],[config]" can't be used with option "[alter]"

startjava created KAFKA-9773: Summary: Option combination "[bootstrap-server],[config]" can't be used with option "[alter]" Key: KAFKA-9773 URL: https://issues.apache.org/jira/browse/KAFKA-9773 Project: K

[jira] [Commented] (KAFKA-9673) Conditionally apply SMTs

[ https://issues.apache.org/jira/browse/KAFKA-9673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068418#comment-17068418 ] Tom Bentley commented on KAFKA-9673: I opened [KIP-585|https://cwiki.apache.org/conf