Cheslack-Postava
scala
a0cbd3bbbeeabae12caa6b41aec31a8f5dfd034b
Diff: https://reviews.apache.org/r/26663/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
---
Thanks,
Ewen Cheslack-Postava
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26663/#review56652
---
On Oct. 14, 2014, 10:33 p.m., Ewen Cheslack-Postava wrote:
>
>
Ms + segment.rollJitterMs; and limit
> > segment.rollJitterMs to an interval of [-config.segmentMs / 2,
> > config.segmentMs / 2]
> >
> > Thoughts?
>
> Ewen Cheslack-Postava wrote:
> I considered all of these options. The reason I went with the appr
---
Thanks,
Ewen Cheslack-Postava
/
Testing
---
Thanks,
Ewen Cheslack-Postava
scala
85498b4a1368d3506f19c4cfc64934e4d0ac4c90
core/src/test/scala/unit/kafka/integration/PrimitiveApiTest.scala
a5386a03b62956bc440b40783247c8cdf7432315
Diff: https://reviews.apache.org/r/26811/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
://reviews.apache.org/r/26770/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
.org/r/26770/#review56956
-------
On Oct. 16, 2014, 8:53 p.m., Ewen Cheslack-Postava wrote:
>
> ---
> This is an automatically generated e-mail. To reply, visit:
> https://reviews
core/src/main/scala/kafka/admin/TopicCommand.scala
7672c5aab4fba8c23b1bb5cd4785c332d300a3fa
core/src/main/scala/kafka/tools/StateChangeLogMerger.scala
d298e7e81acc7427c6cf4796b445966267ca54eb
Diff: https://reviews.apache.org/r/2/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
.org/r/2/#review56958
---
On Oct. 16, 2014, 9:54 p.m., Ewen Cheslack-Postava wrote:
>
> ---
> This is an automatically generated e-mail. To reply, visit:
&g
ab9
clients/src/test/java/org/apache/kafka/clients/producer/RecordAccumulatorTest.java
0762b35abba0551f23047348c5893bb8c9acff14
Diff: https://reviews.apache.org/r/26885/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
The first issue he runs into is one I also find frustrating -- with
cloud providers pushing SSDs, you have to use a pretty large instance
type to get a reasonable test setup. I'm not sure if he couldn't launch
an older type like m1.large (I think some newer AWS accounts aren't able
to) or if he jus
/test/java/org/apache/kafka/clients/producer/RecordAccumulatorTest.java
0762b35abba0551f23047348c5893bb8c9acff14
Diff: https://reviews.apache.org/r/26885/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
I took a quick look at this since I noticed the same issue when testing
your code for the issues you filed. I think the issue is that you're
using all your producers across a thread pool and the snappy library
uses ThreadLocal BufferRecyclers. When new Snappy streams are allocated,
they may be allo
Also, filed https://issues.apache.org/jira/browse/KAFKA-1721 for this
since it either requires an updated version of the upstream library, a
workaround by us, or at a bare minimum clear documentation of the issue.
On Mon, Oct 20, 2014, at 06:23 PM, Ewen Cheslack-Postava wrote:
> I took a qu
/
Testing
---
Thanks,
Ewen Cheslack-Postava
system_test/utils/metrics.py d98d3cdeab00be9ddf4b7032a68da3886e4850c7
Diff: https://reviews.apache.org/r/27060/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
Yeah, the version on Precise is really old, 1.0, and on Trusty is 1.4.
Using the PPA version worked fine for me on Trusty.
-Ewen
On Thu, Oct 23, 2014, at 10:02 AM, Joe Stein wrote:
> hmmm.
>
> I just launched a bootstrap clean room (per release docs). Installed
> latest
> gradle
>
> sudo add-ap
is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26885/#review57513
-------
On Oct. 21, 2014, 12:34 a.m., Ewen Cheslack-Postava wrote:
>
> ---
lient.java
aae8d4a1e98279470587d397cc779a9baf6fee6c
clients/src/test/java/org/apache/kafka/clients/producer/RecordAccumulatorTest.java
0762b35abba0551f23047348c5893bb8c9acff14
Diff: https://reviews.apache.org/r/26885/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
/browse/KAFKA-1721
Repository: kafka
Description
---
KAFKA-1721 Bump snappy-java version for thread-safety fix.
Diffs
-
build.gradle c3e6bb839ad65c512c9db4695d2bb49b82c80da5
Diff: https://reviews.apache.org/r/27124/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
nectionStates, which is private
to NetworkClient. The KafkaClient only exposes the higher level concept of
"ready".
- Ewen
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/26
ka/tools/CleanupObsoleteZkEntries.scala PRE-CREATION
Diff: https://reviews.apache.org/r/27232/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
Testing
---
Thanks,
Ewen Cheslack-Postava
://reviews.apache.org/r/27124/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
Security is planned for 0.9 -- see
https://cwiki.apache.org/confluence/display/KAFKA/Security for the plan,
https://issues.apache.org/jira/browse/KAFKA-1682 for the parent issue
tracking security work, and
https://issues.apache.org/jira/browse/KAFKA-1684 for SSL.
On Sat, Nov 1, 2014, at 08:38 AM,
system_test/utils/kafka_system_test_utils.py
1093b660ebd0cb5ab6d3731d26f151e1bf717f8a
Diff: https://reviews.apache.org/r/27534/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
hanks,
Ewen Cheslack-Postava
f591c
system_test/utils/setup_utils.py 0e8b7f97287ec7bc7a2d91573befe0992092734a
system_test/utils/system_test_utils.py
e8529cd31f9202a50b9c9774037ddc744ff92efa
Diff: https://reviews.apache.org/r/27536/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
ls.py
e8529cd31f9202a50b9c9774037ddc744ff92efa
Diff: https://reviews.apache.org/r/27536/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
--
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27534/#review59898
---
On Nov. 3, 2014, 7:46 p.m., Ewen Cheslack-Postava wrote:
>
> -
E-CREATION
vagrant/README.md PRE-CREATION
vagrant/base.sh PRE-CREATION
vagrant/broker.sh PRE-CREATION
vagrant/zk.sh PRE-CREATION
Diff: https://reviews.apache.org/r/27735/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
l. To reply, visit:
https://reviews.apache.org/r/27534/#review60460
-------
On Nov. 3, 2014, 7:46 p.m., Ewen Cheslack-Postava wrote:
>
> ---
> This is an automatically generated e-ma
> On Nov. 8, 2014, 3:01 a.m., Mayuresh Gharat wrote:
> > system_test/utils/kafka_system_test_utils.py, line 2403
> > <https://reviews.apache.org/r/27534/diff/1/?file=747724#file747724line2403>
> >
> > This causes many system tests (approx 98) to fail
/
Testing
---
Thanks,
Ewen Cheslack-Postava
N
Diff: https://reviews.apache.org/r/27735/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
e-mail. To reply, visit:
https://reviews.apache.org/r/27735/#review60746
-------
On Nov. 11, 2014, 9:51 p.m., Ewen Cheslack-Postava wrote:
>
> ---
> This is an aut
sync
for the synced folder, both with VirtualBox and EC2. Files weren't getting
synced back to the host. For EC2 it makes sense, and I guess the base box must
not have virtualbox guest additions. I've added these to the .gitignore anyway
since it doesn't hurt.
- Ewen
g/r/27735/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
ls.py
e8529cd31f9202a50b9c9774037ddc744ff92efa
Diff: https://reviews.apache.org/r/27536/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
RE-CREATION
Diff: https://reviews.apache.org/r/27735/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
46a4e899ef293c56a931bfa5bcf9a07d07ec5792
Diff: https://reviews.apache.org/r/28121/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
uscates the code and isn't
really worth the minor deduplication.
- Ewen
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/28121/#review62909
to do it this
> > way. Mind explaining the reasoning?
> >
> > I also think this is the right way to do things. However, weighing that
> > with the fact that we are making a somewhat large change to an API that is
> > going away, how bad is implementing pe
Ewen Cheslack-Postava
scala
85eec6fa5d09f302d3d8de13e6c68a9e93304ec5
core/src/test/scala/unit/kafka/zk/ZooKeeperTestHarness.scala
67d9c4bab270c852dc05d47aaa4dd96b0f6039d4
Diff: https://reviews.apache.org/r/28694/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
://reviews.apache.org/r/28735/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
/ProducerRecord.java
<https://reviews.apache.org/r/29468/#comment110269>
Most of the values in ProducerRecord can be null. That condition needs to
be handled here as well as in hashCode()
- Ewen Cheslack-Postava
On Dec. 30, 2014, 12:37 a.m., Parth Brahmbhatt
cs?
clients/src/test/java/org/apache/kafka/clients/producer/RecordAccumulatorTest.java
<https://reviews.apache.org/r/29379/#comment110295>
This would probably be clearer if it was just batchExpirationMs.
- Ewen Cheslack-Postava
On Dec. 23, 2014, 8:44
Diffs (updated)
-
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
525b95e98010cd2053eacd8c321d079bcac2f910
Diff: https://reviews.apache.org/r/28582/diff/
Testing
---
Thanks,
Ewen Cheslack-Postava
the problems. It looks like this no longer
applies to trunk due to 50b734690, so it'll need rebasing.
- Ewen Cheslack-Postava
On Jan. 6, 2015, 6:44 p.m., Parth Brahmbhatt wrote:
>
> ---
> This is an automatically generated e-mail
e requiredAcks parameter.
- Ewen Cheslack-Postava
On Jan. 7, 2015, 12:20 a.m., Gwen Shapira wrote:
>
> ---
> This is an automatically generated e-mail. To reply, v
Bhavesh,
1. I would expect the behavior you're suggesting as well. Any fix for the
JIRA should address this, and I raised that point when reviewing the
current version of the patch.
2. It's currently marked for 0.8.3 so it probably won't make it into 0.8.2,
especially if there isn't a patch for i
y we
check maxWaitMs instead of remainingWaitMs. There's no functional difference,
but I think checking remainingWaitMs instead would be clearer for someone
reading this code.
- Ewen Cheslack-Postava
On Jan. 9, 2015, 3:59 a.m., Ja
getOffsets code.
- Ewen Cheslack-Postava
On Jan. 9, 2015, 2:53 a.m., Jun Rao wrote:
>
> ---
> This is an automatically generated e-mail. To reply, visit:
> https:
[
https://issues.apache.org/jira/browse/KAFKA-6490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-6490.
--
Resolution: Fixed
Fix Version/s: 2.0.0
Closing as this is effectively
[
https://issues.apache.org/jira/browse/KAFKA-7560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-7560.
--
Resolution: Fixed
Fix Version/s: 2.1.0
2.2.0
Issue
[
https://issues.apache.org/jira/browse/KAFKA-7620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-7620.
--
Resolution: Fixed
Fix Version/s: 2.0.2
2.1.1
[
https://issues.apache.org/jira/browse/KAFKA-7551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-7551.
--
Resolution: Fixed
Merged [https://github.com/apache/kafka/pull/5842,] my bad
[
https://issues.apache.org/jira/browse/KAFKA-7503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-7503.
--
Resolution: Fixed
Fix Version/s: 2.0.2
2.1.1
[
https://issues.apache.org/jira/browse/KAFKA-7461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-7461.
--
Resolution: Fixed
Fix Version/s: 2.2.0
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-6566.
--
Resolution: Fixed
> SourceTask#stop() not called after exception raised in p
[
https://issues.apache.org/jira/browse/KAFKA-5807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-5807.
--
Resolution: Fixed
Fix Version/s: 2.0.0
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-6981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-6981.
--
Resolution: Fixed
Issue resolved by pull request 5125
[https://github.com
[
https://issues.apache.org/jira/browse/KAFKA-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-6997.
--
Resolution: Fixed
Issue resolved by pull request 5139
[https://github.com
[
https://issues.apache.org/jira/browse/KAFKA-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-7003.
--
Resolution: Fixed
Fix Version/s: 2.1.0
2.0.0
Issue
[
https://issues.apache.org/jira/browse/KAFKA-7043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-7043.
--
Resolution: Fixed
Fix Version/s: 2.1.0
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-7031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-7031.
--
Resolution: Fixed
Fix Version/s: 2.1.0
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-7009.
--
Resolution: Fixed
Fix Version/s: 2.1.0
0.11.0.3
[
https://issues.apache.org/jira/browse/KAFKA-7056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-7056.
--
Resolution: Fixed
Fix Version/s: 2.1.0
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-7039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-7039.
--
Resolution: Fixed
Fix Version/s: 2.1.0
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-7047.
--
Resolution: Fixed
Reviewer: Ewen Cheslack-Postava
Fix Version/s
[
https://issues.apache.org/jira/browse/KAFKA-7068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-7068.
--
Resolution: Fixed
Fix Version/s: 2.1.0
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-7228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-7228.
--
Resolution: Fixed
> DeadLetterQueue throws a NullPointerExcept
[
https://issues.apache.org/jira/browse/KAFKA-6428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-6428.
--
Resolution: Invalid
Seems it was already setup to report & fail, the repor
[
https://issues.apache.org/jira/browse/KAFKA-6277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-6277.
--
Resolution: Fixed
Fix Version/s: 1.1.0
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-3988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-3988.
--
Resolution: Won't Fix
Not going to fix since KIP-174 is deprecatin
[
https://issues.apache.org/jira/browse/KAFKA-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-4029.
--
Resolution: Fixed
Fix Version/s: 1.1.0
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-6018.
--
Resolution: Fixed
Fix Version/s: 1.1.0
Issue resolved by pull request
Ewen Cheslack-Postava created KAFKA-6506:
Summary: Integration or unit test for Connect REST SSL Support
Key: KAFKA-6506
URL: https://issues.apache.org/jira/browse/KAFKA-6506
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-5142.
--
Resolution: Fixed
Fix Version/s: 1.1.0
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-6253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-6253.
--
Resolution: Fixed
Reviewer: Ewen Cheslack-Postava
Fix Version/s
[
https://issues.apache.org/jira/browse/KAFKA-5987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-5987.
--
Resolution: Fixed
Fix Version/s: 1.1.0
1.2.0
Issue
Ewen Cheslack-Postava created KAFKA-6536:
Summary: Streams quickstart pom.xml is missing versions for a
bunch of plugins
Key: KAFKA-6536
URL: https://issues.apache.org/jira/browse/KAFKA-6536
[
https://issues.apache.org/jira/browse/KAFKA-6513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-6513.
--
Resolution: Fixed
Fix Version/s: 1.2.0
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-6503.
--
Resolution: Fixed
Fix Version/s: 1.2.0
Issue resolved by pull request
Ewen Cheslack-Postava created KAFKA-6580:
Summary: Connect bin scripts have incorrect usage
Key: KAFKA-6580
URL: https://issues.apache.org/jira/browse/KAFKA-6580
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-6439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-6439.
--
Resolution: Not A Bug
> "com.streamsets.pipeline.api.StageException:
[
https://issues.apache.org/jira/browse/KAFKA-6239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-6239.
--
Resolution: Duplicate
> Consume group hung into rebalancing state, now str
[
https://issues.apache.org/jira/browse/KAFKA-6236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-6236.
--
Resolution: Cannot Reproduce
Unresponsive, so we can't track this down. P
[
https://issues.apache.org/jira/browse/KAFKA-4854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-4854.
--
Resolution: Not A Bug
Assignee: Ewen Cheslack-Postava
This behavior is
[
https://issues.apache.org/jira/browse/KAFKA-5471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-5471.
--
Resolution: Fixed
Assignee: Ewen Cheslack-Postava
Updated the link to
[
https://issues.apache.org/jira/browse/KAFKA-5999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-5999.
--
Resolution: Invalid
Assignee: Ewen Cheslack-Postava
Closing as Invalid
Ewen Cheslack-Postava created KAFKA-6676:
Summary: System tests do not handle ZK chroot properly with SCRAM
Key: KAFKA-6676
URL: https://issues.apache.org/jira/browse/KAFKA-6676
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-6728.
--
Resolution: Fixed
Fix Version/s: 1.1.1
1.2.0
Issue
[
https://issues.apache.org/jira/browse/KAFKA-5141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-5141.
--
Resolution: Fixed
Assignee: Ewen Cheslack-Postava
Not sure of the fix
[
https://issues.apache.org/jira/browse/KAFKA-7225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-7225.
--
Resolution: Fixed
> Kafka Connect ConfigProvider not invoked before validat
501 - 600 of 2061 matches
Mail list logo
