[jira] [Updated] (KAFKA-9613) CorruptRecordException: Found record size 0 smaller than minimum record overhead

[ https://issues.apache.org/jira/browse/KAFKA-9613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nandini updated KAFKA-9613: --- Summary: CorruptRecordException: Found record size 0 smaller than minimum record overhead (was:

[GitHub] [kafka] hojongs commented on a change in pull request #11249: Fix wrong link to "Guarantees" part in introduction.html documentation

hojongs commented on a change in pull request #11249: URL: https://github.com/apache/kafka/pull/11249#discussion_r723837977 ## File path: docs/introduction.html ## @@ -144,13 +144,13 @@ -Producers are those client applications that publish (write) events to

[GitHub] [kafka] hojongs commented on a change in pull request #11249: Fix wrong link to "Guarantees" part in introduction.html documentation

hojongs commented on a change in pull request #11249: URL: https://github.com/apache/kafka/pull/11249#discussion_r723837977 ## File path: docs/introduction.html ## @@ -144,13 +144,13 @@ -Producers are those client applications that publish (write) events to

[jira] [Resolved] (KAFKA-13356) Use "delete" retention policy only for stream-stream join windowed stores

[ https://issues.apache.org/jira/browse/KAFKA-13356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13356. - Resolution: Duplicate > Use "delete" retention policy only for stream-stream join

[GitHub] [kafka] C0urante commented on pull request #10563: KAFKA-12487: Add support for cooperative consumer protocol with sink connectors

C0urante commented on pull request #10563: URL: https://github.com/apache/kafka/pull/10563#issuecomment-937395625 @kkonstantine Would you mind giving this another pass? It's been over two months. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [kafka] C0urante commented on pull request #10528: KAFKA-12497: Skip unnecessary source task offset commits

C0urante commented on pull request #10528: URL: https://github.com/apache/kafka/pull/10528#issuecomment-937395176 @rhauch @tombentley could either of you take a look? It'd be nice to get this merged in time for the upcoming 3.1 release; I know I've seen plenty of people led astray by

[GitHub] [kafka] C0urante commented on pull request #10907: KAFKA-10000: Exactly-once support for source connectors (KIP-618)

C0urante commented on pull request #10907: URL: https://github.com/apache/kafka/pull/10907#issuecomment-937394815 @rhauch Is that second pass coming any time soon? It'd be nice if we could get this merged in time for the upcoming 3.1 release. I plan to address the existing comments

[GitHub] [kafka] ableegoldman commented on pull request #11332: MINOR: re-add removed test coverage for 'KAFKA-12983: reset needsJoinPrepare flag'

ableegoldman commented on pull request #11332: URL: https://github.com/apache/kafka/pull/11332#issuecomment-937385978 Merged to trunk and cherrypicked to 3.0 & 2.8 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [kafka] ableegoldman merged pull request #11332: MINOR: re-add removed test coverage for 'KAFKA-12983: reset needsJoinPrepare flag'

ableegoldman merged pull request #11332: URL: https://github.com/apache/kafka/pull/11332 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] ableegoldman commented on pull request #11332: MINOR: re-add removed test coverage for 'KAFKA-12983: reset needsJoinPrepare flag'

ableegoldman commented on pull request #11332: URL: https://github.com/apache/kafka/pull/11332#issuecomment-937381455 Failures are unrelated: `kafka.admin.LeaderElectionCommandTest.testElectionResultOutput()`

[GitHub] [kafka] C0urante commented on pull request #11046: KAFKA-12980: Return empty record batch from Consumer::poll when position advances due to aborted transactions

C0urante commented on pull request #11046: URL: https://github.com/apache/kafka/pull/11046#issuecomment-937378866 @hachikuji could you take a look at this when you have a chance? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [kafka] mjsax commented on pull request #11370: MINOR: remove unneeded size and add lock coarsening to inMemoryKeyValueStore

mjsax commented on pull request #11370: URL: https://github.com/apache/kafka/pull/11370#issuecomment-937373122 Thanks for the PR @showuon! Merged to `trunk`. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [kafka] mjsax merged pull request #11370: MINOR: remove unneeded size and add lock coarsening to inMemoryKeyValueStore

mjsax merged pull request #11370: URL: https://github.com/apache/kafka/pull/11370 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Created] (KAFKA-13357) Controller snapshot contains producer ids records but broker does not

Jose Armando Garcia Sancio created KAFKA-13357: -- Summary: Controller snapshot contains producer ids records but broker does not Key: KAFKA-13357 URL: https://issues.apache.org/jira/browse/KAFKA-13357

[GitHub] [kafka] kowshik commented on a change in pull request #11058: KAFKA-12802 Added a file based cache for consumed remote log metadata for each partition to avoid consuming again incase of broke

kowshik commented on a change in pull request #11058: URL: https://github.com/apache/kafka/pull/11058#discussion_r723625488 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/CommittedOffsetsFile.java ## @@ -0,0 +1,83 @@ +/* + * Licensed

[jira] [Commented] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425153#comment-17425153 ] Manjunath Shettar commented on KAFKA-7996: -- Hello, Our Kafka streams application sometimes gets

[jira] [Assigned] (KAFKA-13356) Use "delete" retention policy only for stream-stream join windowed stores

[ https://issues.apache.org/jira/browse/KAFKA-13356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-13356: --- Assignee: Matthias J. Sax > Use "delete" retention policy only for stream-stream

[jira] [Created] (KAFKA-13356) Use "delete" retention policy only for stream-stream join windowed stores

Guozhang Wang created KAFKA-13356: - Summary: Use "delete" retention policy only for stream-stream join windowed stores Key: KAFKA-13356 URL: https://issues.apache.org/jira/browse/KAFKA-13356 Project:

[GitHub] [kafka] satishd commented on a change in pull request #11058: KAFKA-12802 Added a file based cache for consumed remote log metadata for each partition to avoid consuming again incase of broke

satishd commented on a change in pull request #11058: URL: https://github.com/apache/kafka/pull/11058#discussion_r723456248 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java ## @@ -82,44 +87,148 @@ // User topic

[jira] [Created] (KAFKA-13355) Shutdown broker eventually when unrecoverable exceptions like IOException encountered in RLMM.

Satish Duggana created KAFKA-13355: -- Summary: Shutdown broker eventually when unrecoverable exceptions like IOException encountered in RLMM. Key: KAFKA-13355 URL:

[jira] [Updated] (KAFKA-13354) Topic metrics count request rate inconsistently with other request metrics

[ https://issues.apache.org/jira/browse/KAFKA-13354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Mao updated KAFKA-13354: -- Description: The request rate metrics in BrokerTopicMetrics are incremented per partition in a

[jira] [Created] (KAFKA-13354) Topic metrics count request rate inconsistently with other request metrics

David Mao created KAFKA-13354: - Summary: Topic metrics count request rate inconsistently with other request metrics Key: KAFKA-13354 URL: https://issues.apache.org/jira/browse/KAFKA-13354 Project: Kafka

[GitHub] [kafka] iakunin edited a comment on pull request #10775: KAFKA-12668: Making MockScheduler.schedule safe to use in concurrent code

iakunin edited a comment on pull request #10775: URL: https://github.com/apache/kafka/pull/10775#issuecomment-936453432 @chia7712 @huxihx @jsancio hey guys! Any updates on this pull request? Maybe you have some time to have a look and give me any feedback? -- This is an automated

[GitHub] [kafka] iakunin commented on pull request #10775: KAFKA-12668: Making MockScheduler.schedule safe to use in concurrent code

iakunin commented on pull request #10775: URL: https://github.com/apache/kafka/pull/10775#issuecomment-936453432 @chia7712 @huxihx @jsancio hey guys! Any updates on this pull request? Maybe you have some time to have a look? -- This is an automated message from the Apache Git Service.

[GitHub] [kafka] C0urante opened a new pull request #11384: MINOR: Improve error message for scale mismatch in Connect logical Decimal types

C0urante opened a new pull request #11384: URL: https://github.com/apache/kafka/pull/11384 ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade

[jira] [Created] (KAFKA-13353) Device or resource busy error while deleting topic

Albert Lozano created KAFKA-13353: - Summary: Device or resource busy error while deleting topic Key: KAFKA-13353 URL: https://issues.apache.org/jira/browse/KAFKA-13353 Project: Kafka Issue

[GitHub] [kafka] mimaison commented on a change in pull request #11220: KAFKA-10777: Add additional configuration to control MirrorMaker 2 internal topics naming convention

mimaison commented on a change in pull request #11220: URL: https://github.com/apache/kafka/pull/11220#discussion_r723328617 ## File path: connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/ReplicationPolicy.java ## @@ -52,9 +52,39 @@ default String

[GitHub] [kafka] satishd commented on pull request #11058: KAFKA-12802 Added a file based cache for consumed remote log metadata for each partition to avoid consuming again incase of broker restarts.

satishd commented on pull request #11058: URL: https://github.com/apache/kafka/pull/11058#issuecomment-935967523 Thanks @kowshik for the review comments. Added inline replies and addressed with the latest commit. -- This is an automated message from the Apache Git Service. To respond

[jira] [Updated] (KAFKA-13352) Kafka Client does not support passwords starting with number in jaas config

[ https://issues.apache.org/jira/browse/KAFKA-13352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vyacheslav Boyko updated KAFKA-13352: - Component/s: clients > Kafka Client does not support passwords starting with number in

[jira] [Updated] (KAFKA-13352) Kafka Client does not support passwords starting with number in jaas config

[ https://issues.apache.org/jira/browse/KAFKA-13352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vyacheslav Boyko updated KAFKA-13352: - Description: I'm trying to connect to Kafka with Apache Camel's component. I have SASL

[jira] [Updated] (KAFKA-13352) Kafka Client does not support passwords starting with number in jaas config

[ https://issues.apache.org/jira/browse/KAFKA-13352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vyacheslav Boyko updated KAFKA-13352: - Description: I'm trying to connect to Kafka with Apache Camel's component. I have SASL

[jira] [Created] (KAFKA-13352) Kafka Client does not support passwords starting with number in jaas config

Vyacheslav Boyko created KAFKA-13352: Summary: Kafka Client does not support passwords starting with number in jaas config Key: KAFKA-13352 URL: https://issues.apache.org/jira/browse/KAFKA-13352

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

[ https://issues.apache.org/jira/browse/KAFKA-9106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17424893#comment-17424893 ] Andras Katona commented on KAFKA-9106: -- Fix Version was set to 2.5.0 but it made to 2.6.0 as

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

[ https://issues.apache.org/jira/browse/KAFKA-9106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andras Katona updated KAFKA-9106: - Fix Version/s: (was: 2.5.0) 2.6.0 > metrics exposed via JMX shoud be

[GitHub] [kafka] mimaison commented on a change in pull request #11249: Fix wrong link to "Guarantees" part in introduction.html documentation

mimaison commented on a change in pull request #11249: URL: https://github.com/apache/kafka/pull/11249#discussion_r723050185 ## File path: docs/introduction.html ## @@ -144,13 +144,13 @@ -Producers are those client applications that publish (write) events

[jira] [Commented] (KAFKA-13346) Kafka Streams fails due to RocksDB Locks Not Available Exception

[ https://issues.apache.org/jira/browse/KAFKA-13346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17424845#comment-17424845 ] Bruno Cadonna commented on KAFKA-13346: --- [~ableegoldman] "org.rocksdb.RocksDBException: No locks

[jira] [Resolved] (KAFKA-7214) Mystic FATAL error

[ https://issues.apache.org/jira/browse/KAFKA-7214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki resolved KAFKA-7214. --- Resolution: Workaround The solution is to avoid low values of

[jira] [Closed] (KAFKA-7214) Mystic FATAL error

[ https://issues.apache.org/jira/browse/KAFKA-7214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki closed KAFKA-7214. - > Mystic FATAL error > -- > > Key:

[jira] [Closed] (KAFKA-6777) Wrong reaction on Out Of Memory situation

[ https://issues.apache.org/jira/browse/KAFKA-6777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki closed KAFKA-6777. - > Wrong reaction on Out Of Memory situation >

[jira] [Closed] (KAFKA-6882) Wrong producer settings may lead to DoS on Kafka Server

[ https://issues.apache.org/jira/browse/KAFKA-6882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki closed KAFKA-6882. - > Wrong producer settings may lead to DoS on Kafka Server >

[jira] [Closed] (KAFKA-8548) Inconsistency in Kafka Documentation

[ https://issues.apache.org/jira/browse/KAFKA-8548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki closed KAFKA-8548. - > Inconsistency in Kafka Documentation >

[jira] [Closed] (KAFKA-9221) Kafka REST Proxy wrongly converts quotes in message when sending json

[ https://issues.apache.org/jira/browse/KAFKA-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki closed KAFKA-9221. - > Kafka REST Proxy wrongly converts quotes in message when sending json >

[jira] [Created] (KAFKA-13351) Add possibility to write kafka headers in Kafka Console Producer

Seweryn Habdank-Wojewodzki created KAFKA-13351: -- Summary: Add possibility to write kafka headers in Kafka Console Producer Key: KAFKA-13351 URL: https://issues.apache.org/jira/browse/KAFKA-13351

[GitHub] [kafka] satishd commented on a change in pull request #11058: KAFKA-12802 Added a file based cache for consumed remote log metadata for each partition to avoid consuming again incase of broke

satishd commented on a change in pull request #11058: URL: https://github.com/apache/kafka/pull/11058#discussion_r722958956 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataSnapshotFile.java ## @@ -0,0 +1,253 @@ +/* + *

[GitHub] [kafka] satishd commented on a change in pull request #11058: KAFKA-12802 Added a file based cache for consumed remote log metadata for each partition to avoid consuming again incase of broke

satishd commented on a change in pull request #11058: URL: https://github.com/apache/kafka/pull/11058#discussion_r722958575 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataSnapshotFile.java ## @@ -0,0 +1,253 @@ +/* + *

[GitHub] [kafka] showuon commented on a change in pull request #11380: KAFKA-13345: Use "delete" cleanup policy for windowed stores if duplicates are enabled

showuon commented on a change in pull request #11380: URL: https://github.com/apache/kafka/pull/11380#discussion_r722946931 ## File path: streams/src/test/java/org/apache/kafka/streams/integration/JoinStoreIntegrationTest.java ## @@ -131,4 +143,50 @@ public void

[GitHub] [kafka] satishd commented on a change in pull request #11058: KAFKA-12802 Added a file based cache for consumed remote log metadata for each partition to avoid consuming again incase of broke

satishd commented on a change in pull request #11058: URL: https://github.com/apache/kafka/pull/11058#discussion_r722946986 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java ## @@ -82,44 +87,148 @@ // User topic

[GitHub] [kafka] showuon commented on a change in pull request #11381: KAFKA-12648: allow users to set a StreamsUncaughtExceptionHandler on individual named topologies

showuon commented on a change in pull request #11381: URL: https://github.com/apache/kafka/pull/11381#discussion_r722928724 ## File path: streams/src/main/java/org/apache/kafka/streams/errors/NamedTopologyException.java ## @@ -0,0 +1,33 @@ +/* + * Licensed to the Apache

[GitHub] [kafka] satishd commented on a change in pull request #11058: KAFKA-12802 Added a file based cache for consumed remote log metadata for each partition to avoid consuming again incase of broke

satishd commented on a change in pull request #11058: URL: https://github.com/apache/kafka/pull/11058#discussion_r722923763 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/CommittedOffsetsFile.java ## @@ -0,0 +1,83 @@ +/* + * Licensed

[GitHub] [kafka] satishd commented on a change in pull request #11058: KAFKA-12802 Added a file based cache for consumed remote log metadata for each partition to avoid consuming again incase of broke

satishd commented on a change in pull request #11058: URL: https://github.com/apache/kafka/pull/11058#discussion_r722911577 ## File path: storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/RemoteLogMetadataSnapshotFile.java ## @@ -0,0 +1,253 @@ +/* + *