[jira] [Commented] (KAFKA-5456) Producer fails with NPE if record is larger than batch size

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

[jira] [Created] (KAFKA-5458) SASL handshake fails for METADATA requests

Sagar Lad created KAFKA-5458: Summary: SASL handshake fails for METADATA requests Key: KAFKA-5458 URL: https://issues.apache.org/jira/browse/KAFKA-5458 Project: Kafka Issue Type: Bug Co

[jira] [Commented] (KAFKA-5456) Producer fails with NPE if record is larger than batch size

[ https://issues.apache.org/jira/browse/KAFKA-5456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051437#comment-16051437 ] Jason Gustafson commented on KAFKA-5456: I think the issue here is a slight change

[jira] [Updated] (KAFKA-5456) Producer fails with NPE if record is larger than batch size

[ https://issues.apache.org/jira/browse/KAFKA-5456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-5456: --- Priority: Blocker (was: Major) > Producer fails with NPE if record is larger than batch size

[jira] [Updated] (KAFKA-5456) Producer fails with NPE if record is larger than batch size

[ https://issues.apache.org/jira/browse/KAFKA-5456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-5456: --- Fix Version/s: 0.11.0.0 > Producer fails with NPE if record is larger than batch size > --

[jira] [Assigned] (KAFKA-5456) Producer fails with NPE if record is larger than batch size

[ https://issues.apache.org/jira/browse/KAFKA-5456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-5456: -- Assignee: Jason Gustafson (was: Apurva Mehta) > Producer fails with NPE if record is l

[jira] [Commented] (KAFKA-4602) KIP-72 Allow putting a bound on memory consumed by Incoming requests

[ https://issues.apache.org/jira/browse/KAFKA-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051313#comment-16051313 ] Peter Davis commented on KAFKA-4602: Does this address increased memory used by decomp

[jira] [Updated] (KAFKA-4602) KIP-72 Allow putting a bound on memory consumed by Incoming requests

[ https://issues.apache.org/jira/browse/KAFKA-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Davis updated KAFKA-4602: --- Attachment: screenshot-1.png > KIP-72 Allow putting a bound on memory consumed by Incoming requests >

[jira] [Commented] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak

[ https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051289#comment-16051289 ] Jun Rao commented on KAFKA-5007: [~huxi_2b], that's a good thought. If we hit an unhandled

[jira] [Commented] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051287#comment-16051287 ] huxihx commented on KAFKA-5432: --- Is it possible that the network outage occurred during your

[jira] [Commented] (KAFKA-5413) Log cleaner fails due to large offset in segment file

[ https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051273#comment-16051273 ] Jun Rao commented on KAFKA-5413: [~Kelvinrutt], yes, getting the last offset from the inde

[jira] [Commented] (KAFKA-5457) MemoryRecordsBuilder.hasRoomfor doesn't take into account the headers while computing available space

[ https://issues.apache.org/jira/browse/KAFKA-5457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051247#comment-16051247 ] ASF GitHub Bot commented on KAFKA-5457: --- GitHub user apurvam opened a pull request:

[jira] [Commented] (KAFKA-4829) Improve logging of StreamTask commits

[ https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051233#comment-16051233 ] Guozhang Wang commented on KAFKA-4829: -- [~stevenschlansker] [~nfo] Please take a look

[jira] [Commented] (KAFKA-4829) Improve logging of StreamTask commits

[ https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051232#comment-16051232 ] ASF GitHub Bot commented on KAFKA-4829: --- GitHub user guozhangwang opened a pull requ

[jira] [Commented] (KAFKA-5449) Flaky test TransactionsTest.testReadCommittedConsumerShouldNotSeeUndecidedData

[ https://issues.apache.org/jira/browse/KAFKA-5449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051230#comment-16051230 ] ASF GitHub Bot commented on KAFKA-5449: --- Github user asfgit closed the pull request

[jira] [Resolved] (KAFKA-5449) Flaky test TransactionsTest.testReadCommittedConsumerShouldNotSeeUndecidedData

[ https://issues.apache.org/jira/browse/KAFKA-5449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5449. Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 3348 [https://github

[jira] [Updated] (KAFKA-5457) MemoryRecordsBuilder.hasRoomfor doesn't take into account the headers while computing available space

[ https://issues.apache.org/jira/browse/KAFKA-5457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5457: Summary: MemoryRecordsBuilder.hasRoomfor doesn't take into account the headers while computing avail

[jira] [Created] (KAFKA-5457) RecordAccumulator.hasRoomfor doesn't take into account the headers while computing available space

Apurva Mehta created KAFKA-5457: --- Summary: RecordAccumulator.hasRoomfor doesn't take into account the headers while computing available space Key: KAFKA-5457 URL: https://issues.apache.org/jira/browse/KAFKA-5457

[jira] [Commented] (KAFKA-5456) Producer fails with NPE if record is larger than batch size

[ https://issues.apache.org/jira/browse/KAFKA-5456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051219#comment-16051219 ] Apurva Mehta commented on KAFKA-5456: - Additionally `MemoryRecordsBuilder.hasRoomFor`

[jira] [Assigned] (KAFKA-5456) Producer fails with NPE if record is larger than batch size

[ https://issues.apache.org/jira/browse/KAFKA-5456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta reassigned KAFKA-5456: --- Assignee: Apurva Mehta > Producer fails with NPE if record is larger than batch size > --

[jira] [Created] (KAFKA-5456) Producer fails with NPE if record is larger than batch size

Matthias J. Sax created KAFKA-5456: -- Summary: Producer fails with NPE if record is larger than batch size Key: KAFKA-5456 URL: https://issues.apache.org/jira/browse/KAFKA-5456 Project: Kafka

[jira] [Commented] (KAFKA-4829) Improve logging of StreamTask commits

[ https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051118#comment-16051118 ] Guozhang Wang commented on KAFKA-4829: -- We have done some similar thing on the broker

[jira] [Commented] (KAFKA-5455) Update java docs for consumer and producer to be up to date for EOS

[ https://issues.apache.org/jira/browse/KAFKA-5455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1605#comment-1605 ] ASF GitHub Bot commented on KAFKA-5455: --- GitHub user apurvam opened a pull request:

[jira] [Commented] (KAFKA-5398) Joins on GlobalKTable don't work properly when combined with Avro and the Confluent Schema Registry

[ https://issues.apache.org/jira/browse/KAFKA-5398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051106#comment-16051106 ] Guozhang Wang commented on KAFKA-5398: -- [~benba] Thanks for reporting this issue. We

[jira] [Commented] (KAFKA-4829) Improve logging of StreamTask commits

[ https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051070#comment-16051070 ] Jeyhun Karimov commented on KAFKA-4829: --- I know these are different concepts. The ma

[jira] [Commented] (KAFKA-4829) Improve logging of StreamTask commits

[ https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16051063#comment-16051063 ] Guozhang Wang commented on KAFKA-4829: -- Yeah I'm with [~stevenschlansker] that it to