On Oct. 21, 2014, 12:18 a.m., Jun Rao wrote:
core/src/main/scala/kafka/server/ReplicaManager.scala, lines 481-506
https://reviews.apache.org/r/26373/diff/3/?file=725140#file725140line481
This doesn't quite fix the original problem though. The original
problem is that if the
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vladimir Tretyakov updated KAFKA-1481:
--
Attachment: KAFKA-1481_2014-10-21_09-14-35.patch
Stop using dashes AND underscores as
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14178039#comment-14178039
]
Vladimir Tretyakov commented on KAFKA-1481:
---
Hi, added last patch
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14178396#comment-14178396
]
Wojciech Kuranowski commented on KAFKA-1718:
I have compiled kafka 0.8.2 with
KAFKA-1634 is orthogonal to 1583 right? (BTW sorry about the delay in
reviewing 1583 - I'm on it.)
KAFKA-1634 shouldn't be too difficult to address so I'm hoping we can
get that in 0.8.2 if not the beta release.
Joel
On Mon, Oct 20, 2014 at 09:14:17PM -0700, Jun Rao wrote:
I move KAFKA-1634 to
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14178519#comment-14178519
]
Sriharsha Chintalapani commented on KAFKA-1718:
---
I ran sizeInBytes for
[
https://issues.apache.org/jira/browse/KAFKA-1721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1721:
-
Component/s: compression
Snappy compressor is not thread safe
[
https://issues.apache.org/jira/browse/KAFKA-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1678:
-
Hey [~gwenshap], I have a freed up engineer this week and next to work on this
ticket is it ok if I assign
Can Kafka-1583 go into 0.8.3 on trunk once ready? It is marked now for
0.9.0.
I am about to move the JIRAs open and patch resolved to 0.8.3 from 0.8.2.
On Tue, Oct 21, 2014 at 11:00 AM, Joel Koshy jjkosh...@gmail.com wrote:
KAFKA-1634 is orthogonal to 1583 right? (BTW sorry about the delay in
[
https://issues.apache.org/jira/browse/KAFKA-1566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1566:
-
Fix Version/s: (was: 0.8.2)
(was: 0.9.0)
0.8.3
Kafka
[
https://issues.apache.org/jira/browse/KAFKA-1700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1700:
-
Fix Version/s: (was: 0.8.2)
0.8.3
examples directory - README and shell scripts
[
https://issues.apache.org/jira/browse/KAFKA-686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-686:
Fix Version/s: (was: 0.8.2)
0.8.3
0.8 Kafka broker should give a better error
[
https://issues.apache.org/jira/browse/KAFKA-438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-438:
Fix Version/s: (was: 0.8.2)
0.8.3
Code cleanup in MessageTest
[
https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1351:
-
Fix Version/s: (was: 0.8.2)
0.8.3
String.format is very expensive in Scala
[
https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1420:
-
Fix Version/s: (was: 0.8.2)
0.8.3
Replace
[
https://issues.apache.org/jira/browse/KAFKA-1561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1561:
-
Fix Version/s: (was: 0.8.2)
0.8.3
Data Loss for Incremented Replica Factor and
[
https://issues.apache.org/jira/browse/KAFKA-1374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1374:
-
Fix Version/s: (was: 0.8.2)
0.8.3
LogCleaner (compaction) does not support
[
https://issues.apache.org/jira/browse/KAFKA-795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-795:
Fix Version/s: (was: 0.8.2)
0.8.3
Improvements to PreferredReplicaLeaderElection
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1660:
-
Fix Version/s: (was: 0.8.2)
0.8.3
Ability to call close() with a timeout on the
[
https://issues.apache.org/jira/browse/KAFKA-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1659:
-
Fix Version/s: (was: 0.8.2)
0.8.3
Ability to cleanly abort the KafkaProducer
[
https://issues.apache.org/jira/browse/KAFKA-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1499:
-
Fix Version/s: (was: 0.8.2)
0.8.3
Broker-side compression configuration
[
https://issues.apache.org/jira/browse/KAFKA-934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-934:
Fix Version/s: (was: 0.8.2)
0.8.3
kafka hadoop consumer and producer use older
[
https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-313:
Fix Version/s: (was: 0.8.2)
0.8.3
Add JSON output and looping options to
[
https://issues.apache.org/jira/browse/KAFKA-1230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1230:
-
Fix Version/s: (was: 0.8.2)
0.8.3
shell script files under bin don't work with
[
https://issues.apache.org/jira/browse/KAFKA-1675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1675:
-
Fix Version/s: (was: 0.8.2)
0.8.3
bootstrapping tidy-up
-
[
https://issues.apache.org/jira/browse/KAFKA-1651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1651:
-
Fix Version/s: (was: 0.8.2)
0.8.3
Removed some extra whitespace in
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1481:
-
Fix Version/s: (was: 0.8.2)
0.8.3
Stop using dashes AND underscores as separators
Hi Ewen,
It seems Leo has fixed the snappy lib for this issue. Here are changes:
https://github.com/xerial/snappy-java/commit/7b86642f75c280debf3c1983053ea7f8635b48a5
Here is Jar with fix:
https://oss.sonatype.org/content/repositories/snapshots/org/xerial/snappy/snappy-java/1.1.1.4-SNAPSHOT/
KAFKA-1583 will only be in trunk. It would be nice if we fix KAFKA-1634 in
0.8.2 too (may need a separate patch). If we can get a patch ready, we can
include it in 0.8.2 final.
Thanks,
Jun
On Tue, Oct 21, 2014 at 8:00 AM, Joel Koshy jjkosh...@gmail.com wrote:
KAFKA-1634 is orthogonal to 1583
On Oct. 21, 2014, 12:18 a.m., Jun Rao wrote:
core/src/main/scala/kafka/server/ReplicaManager.scala, lines 481-506
https://reviews.apache.org/r/26373/diff/3/?file=725140#file725140line481
This doesn't quite fix the original problem though. The original
problem is that if the
On Oct. 21, 2014, 4:44 p.m., Neha Narkhede wrote:
core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala, line 111
https://reviews.apache.org/r/2/diff/2/?file=723448#file723448line111
I ran a quick test on the following reassignment file and it didn't
warn me about
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14178396#comment-14178396
]
Wojciech Kuranowski edited comment on KAFKA-1718 at 10/21/14 4:47 PM:
[
https://issues.apache.org/jira/browse/KAFKA-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14178620#comment-14178620
]
Neha Narkhede commented on KAFKA-1678:
--
There are a few more usability issues with
[
https://issues.apache.org/jira/browse/KAFKA-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14178630#comment-14178630
]
Joe Stein commented on KAFKA-1678:
--
Agreed, can this ticket be an update for those two
[
https://issues.apache.org/jira/browse/KAFKA-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14178637#comment-14178637
]
Neha Narkhede commented on KAFKA-1678:
--
Yes, I don't mind if it is part of the same
[
https://issues.apache.org/jira/browse/KAFKA-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14178646#comment-14178646
]
Gwen Shapira commented on KAFKA-1678:
-
All yours, [~joestein].
add new options for
Note that I added a patch with 0.8.2 documentation to KAFKA-1555 (in
order to document the new min.isr behavior).
We need to get this committed in SVN before the release, and probably
document few more things (new producer for example).
Gwen
On Tue, Oct 21, 2014 at 12:07 PM, Jun Rao
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14178739#comment-14178739
]
Jun Rao commented on KAFKA-1481:
Otis,
Yes, we can include this in the 0.8.2 final
[
https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira reassigned KAFKA-1683:
---
Assignee: Gwen Shapira
Implement a session concept in the socket server
[
https://issues.apache.org/jira/browse/KAFKA-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14178791#comment-14178791
]
Gwen Shapira commented on KAFKA-1687:
-
MiniKDC can be used to test with Kerberos
Joe Stein created KAFKA-1722:
Summary: static analysis code coverage for pci audit needs
Key: KAFKA-1722
URL: https://issues.apache.org/jira/browse/KAFKA-1722
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-1722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1722:
-
Component/s: security
static analysis code coverage for pci audit needs
[
https://issues.apache.org/jira/browse/KAFKA-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14178799#comment-14178799
]
Don Bosco Durai edited comment on KAFKA-1688 at 10/21/14 6:33 PM:
[
https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1555:
--
Reviewer: Joel Koshy (was: Jun Rao)
provide strong consistency with reasonable availability
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14178815#comment-14178815
]
Vladimir Tretyakov commented on KAFKA-1481:
---
Hi, Jun, will be perfect!
Stop
[
https://issues.apache.org/jira/browse/KAFKA-1684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein reassigned KAFKA-1684:
Assignee: Ivan Lyutov
Implement TLS/SSL authentication
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/2/
---
(Updated Oct. 21, 2014, 6:58 p.m.)
Review request for kafka.
Bugs:
[
https://issues.apache.org/jira/browse/KAFKA-1653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14178845#comment-14178845
]
Ewen Cheslack-Postava commented on KAFKA-1653:
--
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-1653:
-
Attachment: KAFKA-1653_2014-10-21_11:57:50.patch
Duplicate broker ids allowed in
[
https://issues.apache.org/jira/browse/KAFKA-1721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14178856#comment-14178856
]
Bhavesh Mistry commented on KAFKA-1721:
---
I have filled
Hi, quick circle back around so folks are aware.
The security tickets are tracked here
https://issues.apache.org/jira/browse/KAFKA/component/12324383/?selectedTab=com.atlassian.jira.jira-projects-plugin:component-issues-panel
If you want to jump in on a ticket please do! If no one is assigned
[
https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14179014#comment-14179014
]
Bhavesh Mistry commented on KAFKA-1710:
---
[~jkreps],
I am sorry I did not get back
[
https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14179014#comment-14179014
]
Bhavesh Mistry edited comment on KAFKA-1710 at 10/21/14 8:26 PM:
[
https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14179014#comment-14179014
]
Bhavesh Mistry edited comment on KAFKA-1710 at 10/21/14 8:28 PM:
[
https://issues.apache.org/jira/browse/KAFKA-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14179014#comment-14179014
]
Bhavesh Mistry edited comment on KAFKA-1710 at 10/21/14 8:29 PM:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26994/
---
Review request for kafka.
Bugs: KAFKA-1719
[
https://issues.apache.org/jira/browse/KAFKA-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-1719:
Attachment: KAFKA-1719.patch
Make mirror maker exit when one consumer/producer thread exits.
[
https://issues.apache.org/jira/browse/KAFKA-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14179047#comment-14179047
]
Jiangjie Qin commented on KAFKA-1719:
-
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14179077#comment-14179077
]
Andrew Olson commented on KAFKA-1647:
-
[~nehanarkhede] Will this correction be
[
https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14179081#comment-14179081
]
Jay Kreps commented on KAFKA-1477:
--
I took a look at this patch in a little more detail,
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14179092#comment-14179092
]
Bhavesh Mistry commented on KAFKA-1481:
---
Hi [~junrao],
Can you please let me know
This is the first candidate for release of Apache Kafka 0.8.2-beta
Release Notes for the 0.8.2-beta release
https://people.apache.org/~joestein/kafka-0.8.2-beta-candidate1/RELEASE_NOTES.html
*** Please download, test and vote by Friday, October 24th, 2pm PT
Kafka's KEYS file containing PGP keys
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14179102#comment-14179102
]
Jun Rao commented on KAFKA-1481:
Thanks for the patch. Some comments below.
20.
[
https://issues.apache.org/jira/browse/KAFKA-1647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1647:
-
Fix Version/s: 0.8.2
Replication offset checkpoints (high water marks) can be lost on hard kills
and
Jun Rao created KAFKA-1723:
--
Summary: make the metrics name in new producer more standard
Key: KAFKA-1723
URL: https://issues.apache.org/jira/browse/KAFKA-1723
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-1723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14179128#comment-14179128
]
Jun Rao commented on KAFKA-1723:
One way to address this issue is to change the jmx name
[
https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14179132#comment-14179132
]
Jun Rao commented on KAFKA-1481:
Bhavesh,
Created a subtask to track the metric name in
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26994/#review57680
---
core/src/main/scala/kafka/tools/MirrorMaker.scala
Hi Jun,
Regarding 4) in your comment, after thinking it for a while I cannot come
up a way to it along with log compaction without adding new fields into the
current format on message set. Do you have a better way that do not require
protocol changes?
Guozhang
On Mon, Oct 20, 2014 at 9:53 AM,
[
https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy reopened KAFKA-1555:
---
I'm reopening this so we won't forget about the documentation patch.
If you prefer, we can open a
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24676/#review57235
---
Very nicely done.
These are all minor comments - all but one
[
https://issues.apache.org/jira/browse/KAFKA-1583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14179460#comment-14179460
]
Joel Koshy commented on KAFKA-1583:
---
I posted review comments, mostly minor.
Did you
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14179472#comment-14179472
]
Jun Rao commented on KAFKA-1718:
Yes, the broker does recompress all messages in the
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14179485#comment-14179485
]
Evan Huus commented on KAFKA-1718:
--
??I guess your go producer can send multiple
[
https://issues.apache.org/jira/browse/KAFKA-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14179485#comment-14179485
]
Evan Huus edited comment on KAFKA-1718 at 10/22/14 2:26 AM:
75 matches
Mail list logo
