[jira] [Created] (KAFKA-12605) kafka consumer churns through buffer memory iterating over records

2021-04-01 Thread radai rosenblatt (Jira)
radai rosenblatt created KAFKA-12605: Summary: kafka consumer churns through buffer memory iterating over records Key: KAFKA-12605 URL: https://issues.apache.org/jira/browse/KAFKA-12605 Project

[jira] [Created] (KAFKA-9998) KafkaProducer.close(timeout) still may block indefinitely

2020-05-14 Thread radai rosenblatt (Jira)
radai rosenblatt created KAFKA-9998: --- Summary: KafkaProducer.close(timeout) still may block indefinitely Key: KAFKA-9998 URL: https://issues.apache.org/jira/browse/KAFKA-9998 Project: Kafka

[jira] [Created] (KAFKA-9855) dont waste memory allocating Struct and values objects for Schemas with no fields

2020-04-12 Thread radai rosenblatt (Jira)
radai rosenblatt created KAFKA-9855: --- Summary: dont waste memory allocating Struct and values objects for Schemas with no fields Key: KAFKA-9855 URL: https://issues.apache.org/jira/browse/KAFKA-9855

[jira] [Created] (KAFKA-8366) partitions of topics being deleted show up in the offline partitions metric

2019-05-14 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-8366: --- Summary: partitions of topics being deleted show up in the offline partitions metric Key: KAFKA-8366 URL: https://issues.apache.org/jira/browse/KAFKA-8366

[jira] [Resolved] (KAFKA-7475) print the actual cluster bootstrap address on authentication failures

2018-10-11 Thread radai rosenblatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radai rosenblatt resolved KAFKA-7475. - Resolution: Fixed Reviewer: Rajini Sivaram Fix Version/s: 2.1.0 > pr

[jira] [Created] (KAFKA-7475) print the actual cluster bootstrap address on authentication failures

2018-10-02 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-7475: --- Summary: print the actual cluster bootstrap address on authentication failures Key: KAFKA-7475 URL: https://issues.apache.org/jira/browse/KAFKA-7475 Project

[jira] [Created] (KAFKA-7473) allow configuring kafka client configs to not warn for unknown config peoperties

2018-10-02 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-7473: --- Summary: allow configuring kafka client configs to not warn for unknown config peoperties Key: KAFKA-7473 URL: https://issues.apache.org/jira/browse/KAFKA-7473

[jira] [Created] (KAFKA-6648) Fetcher.getTopicMetadata() only returns "healthy" partitions, not all

2018-03-13 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-6648: --- Summary: Fetcher.getTopicMetadata() only returns "healthy" partitions, not all Key: KAFKA-6648 URL: https://issues.apache.org/jira/browse/KAFKA-6648

[jira] [Created] (KAFKA-6622) GroupMetadataManager.loadGroupsAndOffsets decompresses record batch needlessly

2018-03-07 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-6622: --- Summary: GroupMetadataManager.loadGroupsAndOffsets decompresses record batch needlessly Key: KAFKA-6622 URL: https://issues.apache.org/jira/browse/KAFKA-6622

[jira] [Resolved] (KAFKA-6345) NetworkClient.inFlightRequestCount() is not thread safe, causing ConcurrentModificationExceptions when sensors are read

2018-02-08 Thread radai rosenblatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radai rosenblatt resolved KAFKA-6345. - Resolution: Fixed > NetworkClient.inFlightRequestCount() is not thread safe, caus

[jira] [Created] (KAFKA-6345) NetworkClient.inFlightRequestCount() is not thread safe, causing ConcurrentModificationExceptions when sensors are read

2017-12-11 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-6345: --- Summary: NetworkClient.inFlightRequestCount() is not thread safe, causing ConcurrentModificationExceptions when sensors are read Key: KAFKA-6345 URL: https

[jira] [Created] (KAFKA-6216) kafka logs for misconfigured ssl clients are unhelpful

2017-11-15 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-6216: --- Summary: kafka logs for misconfigured ssl clients are unhelpful Key: KAFKA-6216 URL: https://issues.apache.org/jira/browse/KAFKA-6216 Project: Kafka

[GitHub] kafka pull request #4223: when closing a socket in response to an IOExceptio...

2017-11-15 Thread radai-rosenblatt
GitHub user radai-rosenblatt opened a pull request: https://github.com/apache/kafka/pull/4223 when closing a socket in response to an IOException, also print the root issue if closing fails `Selector.pollSelectionKeys()` attempts to close the channel in response to an Exception

[jira] [Created] (KAFKA-5190) builds with low parallelism exhaust system open files and crash

2017-05-07 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-5190: --- Summary: builds with low parallelism exhaust system open files and crash Key: KAFKA-5190 URL: https://issues.apache.org/jira/browse/KAFKA-5190 Project: Kafka

[jira] [Created] (KAFKA-5189) trunk unstable - DescribeConsumerGroupTest.testDescribeGroupWithNewConsumerWithShortInitializationTimeout fails 90% of times

2017-05-07 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-5189: --- Summary: trunk unstable - DescribeConsumerGroupTest.testDescribeGroupWithNewConsumerWithShortInitializationTimeout fails 90% of times Key: KAFKA-5189 URL: https

[GitHub] kafka pull request #2025: KAFKA-4293 - improve ByteBufferMessageSet.deepIter...

2017-05-06 Thread radai-rosenblatt
Github user radai-rosenblatt closed the pull request at: https://github.com/apache/kafka/pull/2025 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so

[GitHub] kafka pull request #2814: change language level from java 7 to 8

2017-04-05 Thread radai-rosenblatt
Github user radai-rosenblatt closed the pull request at: https://github.com/apache/kafka/pull/2814 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so

[GitHub] kafka pull request #2814: change language level from java 7 to 8

2017-04-05 Thread radai-rosenblatt
GitHub user radai-rosenblatt opened a pull request: https://github.com/apache/kafka/pull/2814 change language level from java 7 to 8 now that KIP-118 has passed, and there are no major releases coming before 0.11 Signed-off-by: radai-rosenblatt <radai.rose

[GitHub] kafka pull request #2637: throw NoOffsetForPartitionException from poll once...

2017-03-03 Thread radai-rosenblatt
GitHub user radai-rosenblatt opened a pull request: https://github.com/apache/kafka/pull/2637 throw NoOffsetForPartitionException from poll once for all TopicPartitions affected Signed-off-by: radai-rosenblatt <radai.rosenbl...@gmail.com> You can merge this pull r

[jira] [Created] (KAFKA-4839) throw NoOffsetForPartitionException once for all assigned partitions from poll

2017-03-03 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-4839: --- Summary: throw NoOffsetForPartitionException once for all assigned partitions from poll Key: KAFKA-4839 URL: https://issues.apache.org/jira/browse/KAFKA-4839

[GitHub] kafka pull request #2330: KAFKA-4602 - KIP-72 - Allow putting a bound on mem...

2017-01-06 Thread radai-rosenblatt
GitHub user radai-rosenblatt opened a pull request: https://github.com/apache/kafka/pull/2330 KAFKA-4602 - KIP-72 - Allow putting a bound on memory consumed by Incoming requests this is the initial implementation. You can merge this pull request into a Git repository by running

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

2017-01-05 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-4602: --- Summary: KIP-72 Allow putting a bound on memory consumed by Incoming requests Key: KAFKA-4602 URL: https://issues.apache.org/jira/browse/KAFKA-4602 Project

[jira] [Updated] (KAFKA-4550) current trunk unstable

2016-12-15 Thread radai rosenblatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radai rosenblatt updated KAFKA-4550: Issue Type: Sub-task (was: Bug) Parent: KAFKA-2054 > current trunk unsta

[jira] [Updated] (KAFKA-4550) current trunk unstable

2016-12-15 Thread radai rosenblatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radai rosenblatt updated KAFKA-4550: Description: on latest trunk (commit hash 908b6d1148df963d21a70aaa73a7a87571b965a9) when

[jira] [Created] (KAFKA-4550) current trunk unstable

2016-12-15 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-4550: --- Summary: current trunk unstable Key: KAFKA-4550 URL: https://issues.apache.org/jira/browse/KAFKA-4550 Project: Kafka Issue Type: Bug Affects

[jira] [Updated] (KAFKA-4550) current trunk unstable

2016-12-15 Thread radai rosenblatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radai rosenblatt updated KAFKA-4550: Attachment: run5.log run4.log run3.log run2

[jira] [Updated] (KAFKA-4250) make ProducerRecord and ConsumerRecord extensible

2016-11-30 Thread radai rosenblatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radai rosenblatt updated KAFKA-4250: Fix Version/s: (was: 0.10.1.1) > make ProducerRecord and ConsumerRecord extensi

[jira] [Updated] (KAFKA-4250) make ProducerRecord and ConsumerRecord extensible

2016-11-30 Thread radai rosenblatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radai rosenblatt updated KAFKA-4250: Fix Version/s: (was: 0.10.2.0) 0.10.1.1 > make ProducerRec

[jira] [Resolved] (KAFKA-4011) allow sizing RequestQueue in bytes

2016-11-14 Thread radai rosenblatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radai rosenblatt resolved KAFKA-4011. - Resolution: Won't Fix Fix Version/s: (was: 0.10.2.0) this was the original KIP

[GitHub] kafka pull request #1714: KAFKA-4011 - fix issues and beef up tests around B...

2016-11-14 Thread radai-rosenblatt
Github user radai-rosenblatt closed the pull request at: https://github.com/apache/kafka/pull/1714 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so

[GitHub] kafka pull request #2025: KAFKA-4293 - improve ByteBufferMessageSet.deepIter...

2016-10-13 Thread radai-rosenblatt
GitHub user radai-rosenblatt opened a pull request: https://github.com/apache/kafka/pull/2025 KAFKA-4293 - improve ByteBufferMessageSet.deepIterator() performance by relying on underlying stream's available() implementation also: provided better available

[jira] [Created] (KAFKA-4293) ByteBufferMessageSet.deepIterator burns CPU catching EOFExceptions

2016-10-11 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-4293: --- Summary: ByteBufferMessageSet.deepIterator burns CPU catching EOFExceptions Key: KAFKA-4293 URL: https://issues.apache.org/jira/browse/KAFKA-4293 Project

[jira] [Created] (KAFKA-4289) CPU wasted on reflection calls initializing short-lived loggers

2016-10-10 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-4289: --- Summary: CPU wasted on reflection calls initializing short-lived loggers Key: KAFKA-4289 URL: https://issues.apache.org/jira/browse/KAFKA-4289 Project: Kafka

[GitHub] kafka pull request #2006: KAFKA-4289 - moved short-lived loggers to companio...

2016-10-10 Thread radai-rosenblatt
GitHub user radai-rosenblatt opened a pull request: https://github.com/apache/kafka/pull/2006 KAFKA-4289 - moved short-lived loggers to companion objects Signed-off-by: radai-rosenblatt <radai.rosenbl...@gmail.com> You can merge this pull request into a Git repository by r

[jira] [Commented] (KAFKA-4250) make ProducerRecord and ConsumerRecord extensible

2016-10-04 Thread radai rosenblatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546226#comment-15546226 ] radai rosenblatt commented on KAFKA-4250: - PR up - https://github.com/apache/kafka/pull/1961

[jira] [Created] (KAFKA-4250) make ProducerRecord and ConsumerRecord extensible

2016-10-04 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-4250: --- Summary: make ProducerRecord and ConsumerRecord extensible Key: KAFKA-4250 URL: https://issues.apache.org/jira/browse/KAFKA-4250 Project: Kafka Issue

[GitHub] kafka pull request #1930: KAFKA-4228 - make producer close on sender thread ...

2016-09-28 Thread radai-rosenblatt
GitHub user radai-rosenblatt opened a pull request: https://github.com/apache/kafka/pull/1930 KAFKA-4228 - make producer close on sender thread death, make consumer shutdown on failure to rebalance, and make MM die on any of the above. the JIRA issue (https://issues.apache.org/jira

[jira] [Updated] (KAFKA-4228) Sender thread death leaves KafkaProducer in a bad state

2016-09-28 Thread radai rosenblatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radai rosenblatt updated KAFKA-4228: Description: a KafkaProducer's Sender thread may die: {noformat} 2016/09/28 00:28:01.065

[jira] [Created] (KAFKA-4228) Sender thread death leaves KafkaProducer in a bad state

2016-09-28 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-4228: --- Summary: Sender thread death leaves KafkaProducer in a bad state Key: KAFKA-4228 URL: https://issues.apache.org/jira/browse/KAFKA-4228 Project: Kafka

[GitHub] kafka pull request #1813: make mirror maker threads daemons and make sure an...

2016-09-01 Thread radai-rosenblatt
GitHub user radai-rosenblatt opened a pull request: https://github.com/apache/kafka/pull/1813 make mirror maker threads daemons and make sure any uncaught exceptions are logged You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] kafka pull request #1714: KAFKA-4011 - fix issues and beef up tests around B...

2016-08-08 Thread radai-rosenblatt
GitHub user radai-rosenblatt opened a pull request: https://github.com/apache/kafka/pull/1714 KAFKA-4011 - fix issues and beef up tests around ByteBoundedBlockingQueue as discussed under KIP-72 You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] kafka pull request #1710: KAFKA-4025 - make sure file.encoding system proper...

2016-08-07 Thread radai-rosenblatt
GitHub user radai-rosenblatt opened a pull request: https://github.com/apache/kafka/pull/1710 KAFKA-4025 - make sure file.encoding system property is set to UTF-8 when calling rat You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] kafka pull request #1708: KAFKA-4025 - make sure file.encoding system proper...

2016-08-07 Thread radai-rosenblatt
Github user radai-rosenblatt closed the pull request at: https://github.com/apache/kafka/pull/1708 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so

[GitHub] kafka pull request #1708: KAFKA-4025 - make sure file.encoding system proper...

2016-08-06 Thread radai-rosenblatt
GitHub user radai-rosenblatt opened a pull request: https://github.com/apache/kafka/pull/1708 KAFKA-4025 - make sure file.encoding system property is set to UTF-8 when invoking the rat task reset back to previous value after. You can merge this pull request into a Git repository

[jira] [Updated] (KAFKA-4025) build fails on windows due to rat target output encoding

2016-08-06 Thread radai rosenblatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radai rosenblatt updated KAFKA-4025: Attachment: windows build debug output.txt debug output for running the rat task on windows

[jira] [Updated] (KAFKA-4025) build fails on windows due to rat target output encoding

2016-08-06 Thread radai rosenblatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radai rosenblatt updated KAFKA-4025: Environment: windows 7, either regular command prompt or git bash (was: windows 7, wither

[jira] [Created] (KAFKA-4025) build fails on windows due to rat target output encoding

2016-08-06 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-4025: --- Summary: build fails on windows due to rat target output encoding Key: KAFKA-4025 URL: https://issues.apache.org/jira/browse/KAFKA-4025 Project: Kafka

[jira] [Created] (KAFKA-4011) allow sizing RequestQueue in bytes

2016-08-01 Thread radai rosenblatt (JIRA)
radai rosenblatt created KAFKA-4011: --- Summary: allow sizing RequestQueue in bytes Key: KAFKA-4011 URL: https://issues.apache.org/jira/browse/KAFKA-4011 Project: Kafka Issue Type