[jira] [Commented] (KAFKA-5010) Log cleaner crashed with BufferOverflowException when writing to the writeBuffer

[ https://issues.apache.org/jira/browse/KAFKA-5010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771627#comment-16771627 ] Li Haijun commented on KAFKA-5010: -- Hi Shuai Lin, we encounterd the relative problem recently, how could

[jira] [Created] (KAFKA-7948) Feature to enable json field order retention in the JsonConverter

Jonathan Court created KAFKA-7948: - Summary: Feature to enable json field order retention in the JsonConverter Key: KAFKA-7948 URL: https://issues.apache.org/jira/browse/KAFKA-7948 Project: Kafka

[jira] [Updated] (KAFKA-7948) Feature to enable json field order retention in the JsonConverter

[ https://issues.apache.org/jira/browse/KAFKA-7948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Court updated KAFKA-7948: -- Flags: Patch > Feature to enable json field order retention in the JsonConverter >

[jira] [Commented] (KAFKA-7948) Feature to enable json field order retention in the JsonConverter

[ https://issues.apache.org/jira/browse/KAFKA-7948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771560#comment-16771560 ] ASF GitHub Bot commented on KAFKA-7948: --- joncourt commented on pull request #6289: KAFKA-7948:

[jira] [Commented] (KAFKA-7945) ExpiringCredentialRefreshingLogin - timeout value is negative

[ https://issues.apache.org/jira/browse/KAFKA-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771528#comment-16771528 ] ASF GitHub Bot commented on KAFKA-7945: --- rondagostino commented on pull request #6288: KAFKA-7945:

[jira] [Commented] (KAFKA-7945) ExpiringCredentialRefreshingLogin - timeout value is negative

[ https://issues.apache.org/jira/browse/KAFKA-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771526#comment-16771526 ] hackerwin7 commented on KAFKA-7945: --- It seems that _expiringCredential.startTimeMs()_ in

[jira] [Assigned] (KAFKA-7945) ExpiringCredentialRefreshingLogin - timeout value is negative

[ https://issues.apache.org/jira/browse/KAFKA-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ron Dagostino reassigned KAFKA-7945: Assignee: Ron Dagostino > ExpiringCredentialRefreshingLogin - timeout value is negative >

[jira] [Commented] (KAFKA-5510) Streams should commit all offsets regularly

[ https://issues.apache.org/jira/browse/KAFKA-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771512#comment-16771512 ] Matthias J. Sax commented on KAFKA-5510: With https://issues.apache.org/jira/browse/KAFKA-4682 

[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=16771504#comment-16771504 ] Matthias J. Sax commented on KAFKA-7933: PR for troubleshooting: 

[jira] [Commented] (KAFKA-7778) Add KTable.suppress to Scala API

[ https://issues.apache.org/jira/browse/KAFKA-7778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771502#comment-16771502 ] Matthias J. Sax commented on KAFKA-7778: {quote}I propose we just add it to KIP-328 and send out

[jira] [Created] (KAFKA-7947) Flaky Test EpochDrivenReplicationProtocolAcceptanceTest #shouldFollowLeaderEpochBasicWorkflow

Matthias J. Sax created KAFKA-7947: -- Summary: Flaky Test EpochDrivenReplicationProtocolAcceptanceTest #shouldFollowLeaderEpochBasicWorkflow Key: KAFKA-7947 URL: https://issues.apache.org/jira/browse/KAFKA-7947

[jira] [Created] (KAFKA-7946) Flaky Test DeleteConsumerGroupsTest#testDeleteNonEmptyGroup

Matthias J. Sax created KAFKA-7946: -- Summary: Flaky Test DeleteConsumerGroupsTest#testDeleteNonEmptyGroup Key: KAFKA-7946 URL: https://issues.apache.org/jira/browse/KAFKA-7946 Project: Kafka

[jira] [Commented] (KAFKA-7945) ExpiringCredentialRefreshingLogin - timeout value is negative

[ https://issues.apache.org/jira/browse/KAFKA-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771424#comment-16771424 ] Ismael Juma commented on KAFKA-7945: Also cc [~rndgstn] > ExpiringCredentialRefreshingLogin -

[jira] [Commented] (KAFKA-7945) ExpiringCredentialRefreshingLogin - timeout value is negative

[ https://issues.apache.org/jira/browse/KAFKA-7945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771423#comment-16771423 ] Ismael Juma commented on KAFKA-7945: Cc [~rsivaram] > ExpiringCredentialRefreshingLogin - timeout

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771408#comment-16771408 ] Patrik Kleindl commented on KAFKA-5998: --- [~guozhang] [~mjsax] Not sure if it helps, but I found an

[jira] [Created] (KAFKA-7945) ExpiringCredentialRefreshingLogin - timeout value is negative

Denis Ogun created KAFKA-7945: - Summary: ExpiringCredentialRefreshingLogin - timeout value is negative Key: KAFKA-7945 URL: https://issues.apache.org/jira/browse/KAFKA-7945 Project: Kafka Issue

[jira] [Updated] (KAFKA-7487) DumpLogSegments reports mismatches for indexed offsets which are not at the start of a record batch

[ https://issues.apache.org/jira/browse/KAFKA-7487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-7487: --- Fix Version/s: 2.3.0 > DumpLogSegments reports mismatches for indexed offsets which are not at the

[jira] [Commented] (KAFKA-7487) DumpLogSegments reports mismatches for indexed offsets which are not at the start of a record batch

[ https://issues.apache.org/jira/browse/KAFKA-7487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771330#comment-16771330 ] ASF GitHub Bot commented on KAFKA-7487: --- ijuma commented on pull request #5756: KAFKA-7487:

[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=16771322#comment-16771322 ] ASF GitHub Bot commented on KAFKA-7895: --- vvcephei commented on pull request #6286: KAFKA-7895: fix

[jira] [Commented] (KAFKA-7492) Explain `null` handling for reduce and aggregate

[ https://issues.apache.org/jira/browse/KAFKA-7492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771310#comment-16771310 ] ASF GitHub Bot commented on KAFKA-7492: --- asutosh936 commented on pull request #6285: KAFKA-7492 :

[jira] [Commented] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91)

[ https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771312#comment-16771312 ] ASF GitHub Bot commented on KAFKA-5886: --- ijuma commented on pull request #3849: KAFKA-5886:

[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=16771275#comment-16771275 ] ASF GitHub Bot commented on KAFKA-7895: --- mjsax commented on pull request #6278: KAFKA-7895: Fix

[jira] [Commented] (KAFKA-7935) UNSUPPORTED_COMPRESSION_TYPE if ReplicaManager.getLogConfig returns None

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

[jira] [Commented] (KAFKA-7778) Add KTable.suppress to Scala API

[ https://issues.apache.org/jira/browse/KAFKA-7778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771266#comment-16771266 ] John Roesler commented on KAFKA-7778: - Hmm. I guess this is a public API change, but then again, it

[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

[jira] [Created] (KAFKA-7944) Add more natural Suppress test

John Roesler created KAFKA-7944: --- Summary: Add more natural Suppress test Key: KAFKA-7944 URL: https://issues.apache.org/jira/browse/KAFKA-7944 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-7943) Add Suppress system test with caching disabled.

John Roesler created KAFKA-7943: --- Summary: Add Suppress system test with caching disabled. Key: KAFKA-7943 URL: https://issues.apache.org/jira/browse/KAFKA-7943 Project: Kafka Issue Type:

[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

[jira] [Commented] (KAFKA-7934) Optimize restore for windowed and session stores

[ https://issues.apache.org/jira/browse/KAFKA-7934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771164#comment-16771164 ] John Roesler commented on KAFKA-7934: - Thanks [~mjsax], this is a really good idea.   Just adding a

[jira] [Assigned] (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 reassigned KAFKA-7932: --- Assignee: John Roesler > Streams needs to handle new Producer exceptions >

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

[ https://issues.apache.org/jira/browse/KAFKA-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771165#comment-16771165 ] John Roesler commented on KAFKA-7932: - Note, apparently, `Producer.initTransactions()` has been

[jira] [Commented] (KAFKA-6755) MaskField SMT should optionally take a literal value to use instead of using null

[ https://issues.apache.org/jira/browse/KAFKA-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16771119#comment-16771119 ] ASF GitHub Bot commented on KAFKA-6755: --- Nimfadora commented on pull request #6284: [WIP]

[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=16771095#comment-16771095 ] Michael Bragg commented on KAFKA-7895: -- Hi [~vvcephei] Thanks for your proposed fix, sounds

[jira] [Created] (KAFKA-7942) Monitoring consumer lag by time

Yining Liu created KAFKA-7942: - Summary: Monitoring consumer lag by time Key: KAFKA-7942 URL: https://issues.apache.org/jira/browse/KAFKA-7942 Project: Kafka Issue Type: Wish

[jira] [Assigned] (KAFKA-7922) Returned authorized operations in describe responses (KIP-430)

[ https://issues.apache.org/jira/browse/KAFKA-7922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-7922: - Assignee: Manikumar (was: Rajini Sivaram) > Returned authorized operations in describe

[jira] [Resolved] (KAFKA-6569) Reflection in OffsetIndex and TimeIndex construction

[ https://issues.apache.org/jira/browse/KAFKA-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-6569. Resolution: Fixed Fix Version/s: 2.3.0 > Reflection in OffsetIndex and TimeIndex

[jira] [Commented] (KAFKA-6569) Reflection in OffsetIndex and TimeIndex construction

[ https://issues.apache.org/jira/browse/KAFKA-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16770845#comment-16770845 ] ASF GitHub Bot commented on KAFKA-6569: --- ijuma commented on pull request #4586: KAFKA-6569: Move