[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217246#comment-15217246
]
Swapnesh Gandhi commented on KAFKA-1718:
I am seeing the same issue,
is this comp
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311387#comment-14311387
]
Evan Huus commented on KAFKA-1718:
--
[~guozhang], [~jkreps] my understanding is that while
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14311141#comment-14311141
]
Guozhang Wang commented on KAFKA-1718:
--
[~jkreps] I think the conclusion is that this
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14310958#comment-14310958
]
Jay Kreps commented on KAFKA-1718:
--
[~junrao], [~guozhang] is this still ongoing?
> "Mes
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14181470#comment-14181470
]
Jun Rao commented on KAFKA-1718:
Evan,
Thanks for updating the wiki. The MagicByte curren
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14181348#comment-14181348
]
Evan Huus commented on KAFKA-1718:
--
[~junrao] I already have wiki permissions, so I made
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14180856#comment-14180856
]
Jun Rao commented on KAFKA-1718:
[~guozhang], removing the max message size may be a bigge
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14180763#comment-14180763
]
Guozhang Wang commented on KAFKA-1718:
--
Yes, that is what I was thinking about.
> "M
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14180126#comment-14180126
]
Evan Huus commented on KAFKA-1718:
--
??when it gets a partial message from the broker it w
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14180033#comment-14180033
]
Guozhang Wang commented on KAFKA-1718:
--
Since the reason we add the "max.message.size
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14179485#comment-14179485
]
Evan Huus commented on KAFKA-1718:
--
??I guess your go producer can send multiple compress
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14179472#comment-14179472
]
Jun Rao commented on KAFKA-1718:
Yes, the broker does recompress all messages in the messa
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14178796#comment-14178796
]
Wojciech Kuranowski commented on KAFKA-1718:
My test is almost the same as in
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14178737#comment-14178737
]
Sriharsha Chintalapani commented on KAFKA-1718:
---
[~noxis] can you share your
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14178519#comment-14178519
]
Sriharsha Chintalapani commented on KAFKA-1718:
---
I ran sizeInBytes for "test
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14178396#comment-14178396
]
Wojciech Kuranowski commented on KAFKA-1718:
I have compiled kafka 0.8.2 with
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14177558#comment-14177558
]
Jun Rao commented on KAFKA-1718:
In trunk, we actually do a size check before and after re
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14177487#comment-14177487
]
Evan Huus commented on KAFKA-1718:
--
That sounds plausible.
1. How do I verify if that is
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14177478#comment-14177478
]
Jun Rao commented on KAFKA-1718:
Another thing that we do on the broker is to assign a new
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14177351#comment-14177351
]
Evan Huus commented on KAFKA-1718:
--
The numbers I put in my original report do take all o
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14177324#comment-14177324
]
Sriharsha Chintalapani commented on KAFKA-1718:
---
[~eapache] there is additio
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14177112#comment-14177112
]
Evan Huus commented on KAFKA-1718:
--
LogOverhead is only 12 bytes; none of the values I pr
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14177107#comment-14177107
]
Sriharsha Chintalapani commented on KAFKA-1718:
---
[~eapache] kafka uses ByteB
23 matches
Mail list logo
