[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing

2020-02-13 Thread Navinder Brar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036093#comment-17036093 ] Navinder Brar commented on KAFKA-9450: -- Sure, [~ableegoldman]. I will create a ticke

[jira] [Commented] (KAFKA-9533) ValueTransform forwards `null` values

2020-02-13 Thread Bruno Cadonna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036099#comment-17036099 ] Bruno Cadonna commented on KAFKA-9533: -- Thank you for picking this up! Ad 1) We do

[jira] [Commented] (KAFKA-9280) Duplicate messages are observed in ACK mode ALL

2020-02-13 Thread VIkram (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036125#comment-17036125 ] VIkram commented on KAFKA-9280: --- Will the consumer FetchRequest\{from=1000} gets served? >

[jira] [Created] (KAFKA-9546) Make FileStreamSourceTask extendable with generic streams

2020-02-13 Thread Csaba Galyo (Jira)
Csaba Galyo created KAFKA-9546: -- Summary: Make FileStreamSourceTask extendable with generic streams Key: KAFKA-9546 URL: https://issues.apache.org/jira/browse/KAFKA-9546 Project: Kafka Issue Typ

[jira] [Created] (KAFKA-9547) Kafka transaction - skip one offset when the application stops and be started again

2020-02-13 Thread Rumel (Jira)
Rumel created KAFKA-9547: Summary: Kafka transaction - skip one offset when the application stops and be started again Key: KAFKA-9547 URL: https://issues.apache.org/jira/browse/KAFKA-9547 Project: Kafka

[jira] [Commented] (KAFKA-9533) ValueTransform forwards `null` values

2020-02-13 Thread Michael Viamari (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036291#comment-17036291 ] Michael Viamari commented on KAFKA-9533: Ok. Great. I'll address the adaptor code

[jira] [Commented] (KAFKA-9319) Run some system tests using TLSv1.3

2020-02-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036295#comment-17036295 ] ASF GitHub Bot commented on KAFKA-9319: --- nizhikov commented on pull request #8106:

[jira] [Commented] (KAFKA-9319) Run some system tests using TLSv1.3

2020-02-13 Thread Nikolay Izhikov (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036297#comment-17036297 ] Nikolay Izhikov commented on KAFKA-9319: Hello, [~rsivaram]. I found two issues

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

2020-02-13 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036300#comment-17036300 ] highluck commented on KAFKA-9455: - [~guozhang] I don't know if I understand.. I'm tryin

[jira] [Commented] (KAFKA-7499) Extend ProductionExceptionHandler to cover serialization exceptions

2020-02-13 Thread highluck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036321#comment-17036321 ] highluck commented on KAFKA-7499: - [~jbfletch], [~mjsax] Is this ticket in progress? If

[jira] [Commented] (KAFKA-9517) KTable Joins Without Materialized Argument Yield Results That Further Joins NPE On

2020-02-13 Thread Paul Snively (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036329#comment-17036329 ] Paul Snively commented on KAFKA-9517: - John, Thanks so much for your prompt attentio

[jira] [Created] (KAFKA-9548) RemoteStorageManager and RemoteLogMetadataManager interfaces.

2020-02-13 Thread Satish Duggana (Jira)
Satish Duggana created KAFKA-9548: - Summary: RemoteStorageManager and RemoteLogMetadataManager interfaces. Key: KAFKA-9548 URL: https://issues.apache.org/jira/browse/KAFKA-9548 Project: Kafka

[jira] [Created] (KAFKA-9549) Local storage implementations for RSM and RLMM which can be used in tests.

2020-02-13 Thread Satish Duggana (Jira)
Satish Duggana created KAFKA-9549: - Summary: Local storage implementations for RSM and RLMM which can be used in tests. Key: KAFKA-9549 URL: https://issues.apache.org/jira/browse/KAFKA-9549 Project: K

[jira] [Assigned] (KAFKA-9548) RemoteStorageManager and RemoteLogMetadataManager interfaces.

2020-02-13 Thread Satish Duggana (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana reassigned KAFKA-9548: - Assignee: Satish Duggana > RemoteStorageManager and RemoteLogMetadataManager interfaces.

[jira] [Assigned] (KAFKA-9533) ValueTransform forwards `null` values

2020-02-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9533: -- Assignee: Michael Viamari > ValueTransform forwards `null` values > --

[jira] [Commented] (KAFKA-9533) ValueTransform forwards `null` values

2020-02-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036369#comment-17036369 ] Matthias J. Sax commented on KAFKA-9533: [~mviamari] Thanks for picking up this t

[jira] [Created] (KAFKA-9550) RemoteLogManager implementation

2020-02-13 Thread Satish Duggana (Jira)
Satish Duggana created KAFKA-9550: - Summary: RemoteLogManager implementation Key: KAFKA-9550 URL: https://issues.apache.org/jira/browse/KAFKA-9550 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-9551) Alternate WindowKeySchema Implementations

2020-02-13 Thread Michael Viamari (Jira)
Michael Viamari created KAFKA-9551: -- Summary: Alternate WindowKeySchema Implementations Key: KAFKA-9551 URL: https://issues.apache.org/jira/browse/KAFKA-9551 Project: Kafka Issue Type: Impro

[jira] [Updated] (KAFKA-9551) Alternate WindowKeySchema Implementations

2020-02-13 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9551: --- Component/s: streams > Alternate WindowKeySchema Implementations > --

[jira] [Commented] (KAFKA-7499) Extend ProductionExceptionHandler to cover serialization exceptions

2020-02-13 Thread jbfletch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036373#comment-17036373 ] jbfletch commented on KAFKA-7499: - It's in progress 🙂 but thanks for checking in > Exte

[jira] [Commented] (KAFKA-9533) ValueTransform forwards `null` values

2020-02-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036381#comment-17036381 ] ASF GitHub Bot commented on KAFKA-9533: --- mviamari commented on pull request #8108:

[jira] [Commented] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted`

2020-02-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036391#comment-17036391 ] ASF GitHub Bot commented on KAFKA-9545: --- abbccdda commented on pull request #8109:

[jira] [Commented] (KAFKA-8616) Replace ApiVersionsRequest request/response with automated protocol

2020-02-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036407#comment-17036407 ] ASF GitHub Bot commented on KAFKA-8616: --- abbccdda commented on pull request #7052:

[jira] [Commented] (KAFKA-9106) metrics exposed via JMX shoud be configurable

2020-02-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036408#comment-17036408 ] ASF GitHub Bot commented on KAFKA-9106: --- cmccabe commented on pull request #7674: K

[jira] [Created] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

2020-02-13 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9552: -- Summary: Stream should handle OutOfSequence exception thrown from Producer Key: KAFKA-9552 URL: https://issues.apache.org/jira/browse/KAFKA-9552 Project: Kafka

[jira] [Updated] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

2020-02-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9552: --- Description: As of today the stream thread could die from OutOfSequence error: [2020-02-12T07:14:35-0

[jira] [Updated] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

2020-02-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9552: --- Description: As of today the stream thread could die from OutOfSequence error: {code:java} [2020-02-

[jira] [Commented] (KAFKA-9206) Consumer should handle `CORRUPT_MESSAGE` error code in fetch response

2020-02-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036473#comment-17036473 ] ASF GitHub Bot commented on KAFKA-9206: --- agam commented on pull request #8111: KAFK

[jira] [Commented] (KAFKA-8507) Support --bootstrap-server in all command line tools

2020-02-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036528#comment-17036528 ] ASF GitHub Bot commented on KAFKA-8507: --- hachikuji commented on pull request #8023:

[jira] [Commented] (KAFKA-9290) Update IQ related JavaDocs

2020-02-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036566#comment-17036566 ] ASF GitHub Bot commented on KAFKA-9290: --- highluck commented on pull request #8114:

[jira] [Updated] (KAFKA-9254) Updating Kafka Broker configuration dynamically twice reverts log configuration to default

2020-02-13 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-9254: --- Affects Version/s: 1.1.0 > Updating Kafka Broker configuration dynamically twice reverts log > confi

[jira] [Updated] (KAFKA-9254) Updating Kafka Broker configuration dynamically twice reverts log configuration to default

2020-02-13 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-9254: --- Fix Version/s: 1.1.2 > Updating Kafka Broker configuration dynamically twice reverts log > configura

[jira] [Commented] (KAFKA-7644) Worker Re balance enhancements

2020-02-13 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036603#comment-17036603 ] Konstantine Karantasis commented on KAFKA-7644: --- This ticket is similar to

[jira] [Resolved] (KAFKA-7644) Worker Re balance enhancements

2020-02-13 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-7644. --- Resolution: Duplicate > Worker Re balance enhancements >

[jira] [Commented] (KAFKA-9446) Integration test library should provide utilities to assert connector state

2020-02-13 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036609#comment-17036609 ] Konstantine Karantasis commented on KAFKA-9446: --- This is mostly addressed b

[jira] [Comment Edited] (KAFKA-9446) Integration test library should provide utilities to assert connector state

2020-02-13 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036609#comment-17036609 ] Konstantine Karantasis edited comment on KAFKA-9446 at 2/14/20 12:39 AM: --

[jira] [Commented] (KAFKA-9446) Integration test library should provide utilities to assert connector state

2020-02-13 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036610#comment-17036610 ] Chris Egerton commented on KAFKA-9446: -- Sounds good. Thanks for the improvements, [~

[jira] [Resolved] (KAFKA-9446) Integration test library should provide utilities to assert connector state

2020-02-13 Thread Chris Egerton (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-9446. -- Resolution: Fixed > Integration test library should provide utilities to assert connector state

[jira] [Commented] (KAFKA-5866) Let source/sink task to finish their job before exit

2020-02-13 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036622#comment-17036622 ] Konstantine Karantasis commented on KAFKA-5866: --- Returning here to add anot

[jira] [Resolved] (KAFKA-5866) Let source/sink task to finish their job before exit

2020-02-13 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-5866. --- Resolution: Won't Do I'm closing this ticket, as this is a quite old request

[jira] [Resolved] (KAFKA-7381) Parameterize connector rebalancing behavior

2020-02-13 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-7381. --- Resolution: Fixed Marking as {{Fixed}} by [#KAFKA-5505] > Parameterize conne

[jira] [Commented] (KAFKA-7381) Parameterize connector rebalancing behavior

2020-02-13 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17036626#comment-17036626 ] Konstantine Karantasis commented on KAFKA-7381: --- I'll close this ticket, gi

[jira] [Created] (KAFKA-9553) Transaction state loading metric does not count total loading time

2020-02-13 Thread Jason Gustafson (Jira)
Jason Gustafson created KAFKA-9553: -- Summary: Transaction state loading metric does not count total loading time Key: KAFKA-9553 URL: https://issues.apache.org/jira/browse/KAFKA-9553 Project: Kafka

[jira] [Updated] (KAFKA-8507) Support --bootstrap-server in all command line tools

2020-02-13 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-8507: --- Affects Version/s: (was: 2.5.0) > Support --bootstrap-server in all command line tools >