[jira] [Commented] (KAFKA-7927) Read committed receives aborted events

[ https://issues.apache.org/jira/browse/KAFKA-7927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769059#comment-16769059 ] Gabor Somogyi commented on KAFKA-7927: -- [~huxi_2b] that's a good point, will retest

[jira] [Commented] (KAFKA-7880) KafkaConnect should standardize worker thread name

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

[jira] [Comment Edited] (KAFKA-7927) Read committed receives aborted events

[ https://issues.apache.org/jira/browse/KAFKA-7927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769021#comment-16769021 ] huxihx edited comment on KAFKA-7927 at 2/15/19 8:31 AM: [~gsomogy

[jira] [Commented] (KAFKA-7880) KafkaConnect should standardize worker thread name

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

[jira] [Commented] (KAFKA-7880) KafkaConnect should standardize worker thread name

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

[jira] [Commented] (KAFKA-7565) NPE in KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-7565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769204#comment-16769204 ] Alexey Vakhrenev commented on KAFKA-7565: - One more data point: when we removed a

[jira] [Commented] (KAFKA-7882) StateStores are frequently closed during the 'transform' method

[ https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769321#comment-16769321 ] Mateusz Owczarek commented on KAFKA-7882: - I am using this approach only after wi

[jira] [Created] (KAFKA-7933) KTableKTableLeftJoinTest takes an hour to finish

Viktor Somogyi created KAFKA-7933: - Summary: KTableKTableLeftJoinTest takes an hour to finish Key: KAFKA-7933 URL: https://issues.apache.org/jira/browse/KAFKA-7933 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7933) KTableKTableLeftJoinTest takes an hour to finish

[ https://issues.apache.org/jira/browse/KAFKA-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769385#comment-16769385 ] Viktor Somogyi commented on KAFKA-7933: --- For now I only saw this at one instance: h

[jira] [Updated] (KAFKA-7933) KTableKTableLeftJoinTest takes an hour to finish

[ https://issues.apache.org/jira/browse/KAFKA-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi updated KAFKA-7933: -- Priority: Major (was: Critical) > KTableKTableLeftJoinTest takes an hour to finish > -

[jira] [Resolved] (KAFKA-7886) Some partitions are fully truncated during recovery when log.message.format = 0.10.2 & inter.broker.protocol >= 0.11

[ https://issues.apache.org/jira/browse/KAFKA-7886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7886. Resolution: Duplicate Resolving this as a duplicate of KAFKA-7897. This will be included in

[jira] [Commented] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts

[ https://issues.apache.org/jira/browse/KAFKA-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769540#comment-16769540 ] Matthias J. Sax commented on KAFKA-7312: Failed on `2.2`: https://builds.apache.

[jira] [Updated] (KAFKA-7933) KTableKTableLeftJoinTest takes an hour to finish

[ https://issues.apache.org/jira/browse/KAFKA-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7933: --- Affects Version/s: (was: 2.2.0) > KTableKTableLeftJoinTest takes an hour to finish >

[jira] [Updated] (KAFKA-7933) KTableKTableLeftJoinTest takes an hour to finish

[ https://issues.apache.org/jira/browse/KAFKA-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7933: --- Component/s: unit tests > KTableKTableLeftJoinTest takes an hour to finish >

[jira] [Commented] (KAFKA-7799) Fix flaky test RestServerTest.testCORSEnabled

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

[jira] [Commented] (KAFKA-7799) Fix flaky test RestServerTest.testCORSEnabled

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

[jira] [Commented] (KAFKA-7882) StateStores are frequently closed during the 'transform' method

[ https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769611#comment-16769611 ] Mateusz Owczarek commented on KAFKA-7882: - Late record as I understand (correct m

[jira] [Commented] (KAFKA-7933) KTableKTableLeftJoinTest takes an hour to finish

[ https://issues.apache.org/jira/browse/KAFKA-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769638#comment-16769638 ] Matthias J. Sax commented on KAFKA-7933: Happende again:  https://builds.apache.o

[jira] [Commented] (KAFKA-7882) StateStores are frequently closed during the 'transform' method

[ https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769659#comment-16769659 ] Matthias J. Sax commented on KAFKA-7882: {quote}After that I reject all the late

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

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

[jira] [Commented] (KAFKA-7914) LDAP

[ https://issues.apache.org/jira/browse/KAFKA-7914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769766#comment-16769766 ] Jordan Moore commented on KAFKA-7914: - I'll assume this is about having an LDAPAuthor

[jira] [Commented] (KAFKA-7882) StateStores are frequently closed during the 'transform' method

[ https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769587#comment-16769587 ] Matthias J. Sax commented on KAFKA-7882: {quote}After that, I clear my state stor

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769842#comment-16769842 ] John Roesler commented on KAFKA-7895: - Hi all,   I'm proposing [https://github.com/

[jira] [Commented] (KAFKA-6460) Add mocks for state stores used in Streams unit testing

[ https://issues.apache.org/jira/browse/KAFKA-6460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769862#comment-16769862 ] Yishun Guan commented on KAFKA-6460: Sounds good to me [~mjsax] and [~guozhang], the

[jira] [Commented] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

[ https://issues.apache.org/jira/browse/KAFKA-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769912#comment-16769912 ] Peter Davis commented on KAFKA-7088: Encountered this bug today with 0.11.0 client. 

[jira] [Commented] (KAFKA-7884) Docs for message.format.version and log.message.format.version show invalid (corrupt?) "valid values"

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

[jira] [Assigned] (KAFKA-7933) KTableKTableLeftJoinTest takes an hour to finish

[ https://issues.apache.org/jira/browse/KAFKA-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7933: -- Assignee: Matthias J. Sax > KTableKTableLeftJoinTest takes an hour to finish > ---

[jira] [Commented] (KAFKA-7933) KTableKTableLeftJoinTest takes an hour to finish

[ https://issues.apache.org/jira/browse/KAFKA-7933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769918#comment-16769918 ] Matthias J. Sax commented on KAFKA-7933: One more: https://builds.apache.org/job

[jira] [Comment Edited] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

[ https://issues.apache.org/jira/browse/KAFKA-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16769912#comment-16769912 ] Peter Davis edited comment on KAFKA-7088 at 2/16/19 12:58 AM: -

[jira] [Resolved] (KAFKA-7884) Docs for message.format.version and log.message.format.version show invalid (corrupt?) "valid values"

[ https://issues.apache.org/jira/browse/KAFKA-7884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7884. Resolution: Fixed > Docs for message.format.version and log.message.format.version show inv

[jira] [Updated] (KAFKA-7932) Streams needs to handle new Producer exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7932: Affects Version/s: 2.0.0 2.0.1 2.1.0

[jira] [Updated] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7895: Description: Hi, We are using kstreams to get the aggregated counts per vendor(key) within a speci

[jira] [Commented] (KAFKA-7882) StateStores are frequently closed during the 'transform' method

[ https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16770005#comment-16770005 ] John Roesler commented on KAFKA-7882: - My mistake [~nijo], I made an incorrect assump