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
[
https://issues.apache.org/jira/browse/KAFKA-9855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radai rosenblatt reassigned KAFKA-9855:
---
Assignee: radai rosenblatt
> dont waste memory allocating Struct and values objects
[
https://issues.apache.org/jira/browse/KAFKA-9855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radai rosenblatt reassigned KAFKA-9855:
---
Assignee: (was: radai rosenblatt)
> dont waste memory allocating Struct and valu
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
[
https://issues.apache.org/jira/browse/KAFKA-9998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111317#comment-17111317
]
radai rosenblatt commented on KAFKA-9998:
-
i think thats wrong, for several reaso
[
https://issues.apache.org/jira/browse/KAFKA-9998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111317#comment-17111317
]
radai rosenblatt edited comment on KAFKA-9998 at 5/19/20, 4:23 PM:
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: K
[
https://issues.apache.org/jira/browse/KAFKA-12605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radai rosenblatt updated KAFKA-12605:
-
Attachment: Screen Shot 2021-04-01 at 3.55.47 PM.png
> kafka consumer churns through buf
[
https://issues.apache.org/jira/browse/KAFKA-12605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radai rosenblatt updated KAFKA-12605:
-
Description:
we recently conducted analysis on memory allocations by the kafka consumer
[
https://issues.apache.org/jira/browse/KAFKA-12605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17314037#comment-17314037
]
radai rosenblatt commented on KAFKA-12605:
--
only compression type that uses thi
[
https://issues.apache.org/jira/browse/KAFKA-12605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337897#comment-17337897
]
radai rosenblatt commented on KAFKA-12605:
--
PR files against trunk - https://gi
[
https://issues.apache.org/jira/browse/KAFKA-12605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17337897#comment-17337897
]
radai rosenblatt edited comment on KAFKA-12605 at 5/2/21, 12:37 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16800714#comment-16800714
]
radai rosenblatt commented on KAFKA-3539:
-
IIUC, the root of the problem is the k
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
Proje
[
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
> print t
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
Is
[
https://issues.apache.org/jira/browse/KAFKA-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16254473#comment-16254473
]
radai rosenblatt commented on KAFKA-6216:
-
i have a proposed fix to address this h
[
https://issues.apache.org/jira/browse/KAFKA-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radai rosenblatt updated KAFKA-6216:
Description:
if you misconfigure the keystores on an ssl client, you will currently get a
l
[
https://issues.apache.org/jira/browse/KAFKA-6216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radai rosenblatt updated KAFKA-6216:
Affects Version/s: (was: 1.0.0)
0.10.2.1
> kafka logs for misconf
radai rosenblatt created KAFKA-6345:
---
Summary: NetworkClient.inFlightRequestCount() is not thread safe,
causing ConcurrentModificationExceptions when sensors are read
Key: KAFKA-6345
URL: https://issues.apache.o
[
https://issues.apache.org/jira/browse/KAFKA-6345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radai rosenblatt reassigned KAFKA-6345:
---
Assignee: Sean McCauliff
> NetworkClient.inFlightRequestCount() is not thread safe, c
[
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, causing
> Co
[
https://issues.apache.org/jira/browse/KAFKA-6345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radai rosenblatt updated KAFKA-6345:
Fix Version/s: 1.1.0
> NetworkClient.inFlightRequestCount() is not thread safe, causing
> C
radai rosenblatt created KAFKA-6622:
---
Summary: GroupMetadataManager.loadGroupsAndOffsets decompresses
record batch needlessly
Key: KAFKA-6622
URL: https://issues.apache.org/jira/browse/KAFKA-6622
Pr
[
https://issues.apache.org/jira/browse/KAFKA-6622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16390502#comment-16390502
]
radai rosenblatt commented on KAFKA-6622:
-
see PR - https://github.com/apache/kafk
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
Project: Ka
[
https://issues.apache.org/jira/browse/KAFKA-6648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radai rosenblatt updated KAFKA-6648:
Affects Version/s: (was: 1.0.1)
1.0.0
0.11.
[
https://issues.apache.org/jira/browse/KAFKA-6648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
radai rosenblatt updated KAFKA-6648:
Fix Version/s: 2.0.0
> Fetcher.getTopicMetadata() only returns "healthy" partitions, not all
[
https://issues.apache.org/jira/browse/KAFKA-6648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16397306#comment-16397306
]
radai rosenblatt commented on KAFKA-6648:
-
PR is https://github.com/apache/kafka/p
[
https://issues.apache.org/jira/browse/KAFKA-6648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16503665#comment-16503665
]
radai rosenblatt commented on KAFKA-6648:
-
thanks for the ping, i had completely
[
https://issues.apache.org/jira/browse/KAFKA-6648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16504111#comment-16504111
]
radai rosenblatt commented on KAFKA-6648:
-
[~rsivaram] - PR has been updated with
[
https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16504672#comment-16504672
]
radai rosenblatt commented on KAFKA-7012:
-
the attached profile screenshot shows
[
https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16505583#comment-16505583
]
radai rosenblatt commented on KAFKA-7012:
-
my only current hypothesis is that `ke
[
https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16506787#comment-16506787
]
radai rosenblatt commented on KAFKA-7012:
-
no, not all of poll(), just this part:
[
https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16506787#comment-16506787
]
radai rosenblatt edited comment on KAFKA-7012 at 6/9/18 2:06 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16506787#comment-16506787
]
radai rosenblatt edited comment on KAFKA-7012 at 6/9/18 2:06 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16506994#comment-16506994
]
radai rosenblatt commented on KAFKA-7012:
-
that line is meant to handle a (hypoth
[
https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16510122#comment-16510122
]
radai rosenblatt commented on KAFKA-7012:
-
in light of that i think the safe chan
[
https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513037#comment-16513037
]
radai rosenblatt commented on KAFKA-7012:
-
i dont have the time to pick this up r
[
https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513037#comment-16513037
]
radai rosenblatt edited comment on KAFKA-7012 at 6/14/18 9:46 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513037#comment-16513037
]
radai rosenblatt edited comment on KAFKA-7012 at 6/15/18 8:48 PM:
-
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
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: Ka
43 matches
Mail list logo
