Hi,
There is a kafka.tools.TestLogCleaning tool, which is used to stress test
the compaction feature.
This tool validates the correctness of compaction process. This tool can be
improved for perf testing.
I think you want to benchmark server side compaction process. Currently we
have few compact
Jun/Ismail,
I requested Apache Infra to change JIRA workflow to add Closed -> Reopen
transition.
https://issues.apache.org/jira/browse/INFRA-11857
Let me know, If any concerns
Manikumar
e:
> Manikumar,
> Any reason for this. Before the workflow is to open
> a new JIRA if a JIRA closed.
> -Harsha
>
> On Fri, May 20, 2016, at 08:54 PM, Manikumar Reddy wrote:
> > Jun/Ismail,
> >
> > I requested Apache Infra to change JIRA w
+1 (non binding)
On Wed, May 25, 2016 at 4:03 PM, Tom Crayford wrote:
> +1 (non binding)
>
> Agree on log.cleaner.compaction.delay.ms being the better name.
>
> I think this setting is going to be extremely hard to tune for users, and
> worry about adding yet more configuration - Kafka already h
+1 (non-binding)
On Fri, Jun 17, 2016 at 3:37 PM, Rajini Sivaram <
rajinisiva...@googlemail.com> wrote:
> +1 (non-binding)
>
> On Fri, Jun 17, 2016 at 4:45 AM, Grant Henke wrote:
>
> > +1
> >
> > On Thu, Jun 16, 2016 at 8:50 PM, tao xiao wrote:
> >
> > > +1
> > >
> > > On Fri, 17 Jun 2016 at 09
+1 (non-binding)
On Tue, Jun 21, 2016 at 9:16 AM, Ewen Cheslack-Postava
wrote:
> +1 (binding) and thanks for the work on this Grant!
>
> -Ewen
>
> On Mon, Jun 20, 2016 at 12:18 PM, Gwen Shapira wrote:
>
> > +1 (binding)
> >
> > On Mon, Jun 20, 2016 at 12:13 PM, Tom Crayford
> > wrote:
> > > +1
Hi,
consumer.subscribe(Pattern p , ..) method implementation tries to get
metadata of all the topics.
This will throw TopicAuthorizationException on internal topics and other
unauthorized topics.
We may need to move the pattern matching to sever side.
Is this know issue?. If not, I will raise JIR
Hi,
Can we allow ListAcls to take list of resources? This may help when we
have many associated
resources under same principal.
Thanks
Manikumar
On Fri, Jul 15, 2016 at 11:15 AM, Gwen Shapira wrote:
> Thank you, Grant. This is lovely :)
>
> Few comments / requests for clarifications below:
>
Hi,
There are two versions of slf4j-log4j jar in the build. (1.6.1, 1.7.21).
slf4j-log4j12-1.6.1.jar is coming from streams:examples module.
Thanks,
Manikumar
On Tue, Aug 2, 2016 at 8:31 PM, Ismael Juma wrote:
> Hello Kafka users, developers and client-developers,
>
> This is the second candid
ka-0.10.0.1-rc2/RELEASE_NOTES.html
>>
>> When compared to RC1, RC2 contains a fix for a regression where an older
>> version of slf4j-log4j12 was also being included in the libs folder of the
>> binary tarball (KAFKA-4008). Thanks to Manikumar Reddy for reporting the
>&g
+1 (non-binding)
On Wed, Aug 10, 2016 at 8:30 AM, Ewen Cheslack-Postava
wrote:
> +1 (binding), thanks for working on this Vahid.
>
> @Dana - See https://cwiki.apache.org/confluence/display/KAFKA/Bylaws re:
> binding/non-binding, although I now notice that we specify criteria (lazy
> majority) on
Yes, we can add a check. This option works only with 64 bit jvm.
On Jan 15, 2015 6:53 PM, "Jaikiran Pai" wrote:
> I just downloaded the Kafka binary and am trying this on my 32 bit JVM
> (Java 7)? Trying to start Zookeeper or Kafka server keeps failing with
> "Unrecognized VM option 'UseCompre
ProducerFailureHandlingTest.testCannotSendToInternalTopic is failing on
both 0.8.2 and trunk.
Error on 0.8.2:
kafka.api.ProducerFailureHandlingTest > testCannotSendToInternalTopic FAILED
java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.TimeoutException: Failed to update
I am consistently getting these errors. May be transient errors.
On Sun, Jan 18, 2015 at 12:05 AM, Harsha wrote:
> I don't see any failures in tests with the latest trunk or 0.8.2. I ran
> it few times in a loop.
> -Harsha
>
> On Sat, Jan 17, 2015, at 08:38 AM, M
All links are pointing to
https://people.apache.org/~junrao/kafka-0.8.2.0-candidate1/.
They should be https://people.apache.org/~junrao/kafka-0.8.2.0-candidate2/
right?
On Tue, Jan 20, 2015 at 8:32 AM, Jun Rao wrote:
> This is the second candidate for release of Apache Kafka 0.8.2.0. There
> ha
Also Maven artifacts link is not correct
On Wed, Jan 21, 2015 at 9:50 PM, Jun Rao wrote:
> Yes, will send out a new email with the correct links.
>
> Thanks,
>
> Jun
>
> On Wed, Jan 21, 2015 at 3:12 AM, Manikumar Reddy
> wrote:
>
>> All links are pointin
Ok, got it. Link is different from Release Candidate 1.
On Wed, Jan 21, 2015 at 10:01 PM, Jun Rao wrote:
> Is it? You just need to navigate into org, then apache, then kafka, etc.
>
> Thanks,
>
> Jun
>
> On Wed, Jan 21, 2015 at 8:28 AM, Manikumar Reddy
> wrote:
>
&
+1 (Non-binding)
Verified source package, unit tests, release build, topic deletion,
compaction and random testing
On Mon, Jan 26, 2015 at 6:14 AM, Neha Narkhede wrote:
> +1 (binding)
> Verified keys, quick start, unit tests.
>
> On Sat, Jan 24, 2015 at 4:26 PM, Joe Stein wrote:
>
> > That make
I think we should consider to moving to apache curator (KAFKA-873).
Curator is now more mature and a apache top-level project.
On Wed, Feb 4, 2015 at 11:29 AM, Harsha wrote:
> Any reason not to go with apache curator http://curator.apache.org/ .
> -Harsha
> On Tue, Feb 3, 2015, at 09:55 PM, Gu
This may be due to the recent issue reported by Gwen.
https://issues.apache.org/jira/browse/KAFKA-1948
On 2/12/15, Joel Koshy wrote:
> - Can you enable test logging (see the README) and see if you can
> figure out which test is getting stuck or taking forever?
> - A thread-dump may help.
>
> O
Wiki link on Eclipse setup:
https://cwiki.apache.org/confluence/display/KAFKA/Eclipse-Scala-Gradle-Git+Developement+Environment+Setup
On Thu, Feb 19, 2015 at 10:03 PM, Jonathan Rafalski <
jonathan.rafal...@gmail.com> wrote:
> Hello again,
>
> Sorry again to send you guys such a generic error.
Hi,
jira.ini file should be in your home directory. Otherwise it prompts you
for jira username and password.
https://cwiki.apache.org/confluence/display/KAFKA/Patch+submission+and+review
Manikumar
On Mon, Mar 9, 2015 at 9:15 AM, Tong Li wrote:
>
>
> While trying to submit a reviewboard req
Congrats Ismael!!
On Tue, Apr 26, 2016 at 12:03 PM, Ashish Singh wrote:
> Congrats Ismael, well deserved!
>
> On Monday, April 25, 2016, Guozhang Wang wrote:
>
> > Congrats Ismael!
> >
> > On Mon, Apr 25, 2016 at 10:52 PM, Neha Narkhede > > wrote:
> >
> > > The PMC for Apache Kafka has invited
+1
It will be great If we can completely close below issue.
https://issues.apache.org/jira/browse/KAFKA-1843
On Tue, Feb 23, 2016 at 3:25 AM, Joel Koshy wrote:
> +1
>
> Thanks for bringing it up
>
> On Mon, Feb 22, 2016 at 9:36 AM, Ismael Juma wrote:
>
> > Hi all,
> >
> > The new Java produc
+1 for 0.8.2.2 release
On Fri, Aug 14, 2015 at 5:49 PM, Ismael Juma wrote:
> I think this is a good idea as the change is minimal on our side and it has
> been tested in production for some time by the reporter.
>
> Best,
> Ismael
>
> On Fri, Aug 14, 2015 at 1:15 PM, Jun Rao wrote:
>
> > Hi, E
Hi,
We have raised a Apache Infra ticket for migrating site docs from svn ->
git .
Currently, the gitwcsub client only supports using the "asf-site" branch
for site docs.
Infra team is suggesting to create new git repo for site docs.
Infra ticket here:
https://issues.apache.org/jira
oops.. i did not check Ismail's mail.
On Wed, Aug 19, 2015 at 9:25 PM, Manikumar Reddy
wrote:
> Hi,
>
> We have raised a Apache Infra ticket for migrating site docs from svn
> -> git .
> Currently, the gitwcsub client only supports using the "asf-site"
9, 2015 at 8:56 AM, Manikumar Reddy
> wrote:
>
> > oops.. i did not check Ismail's mail.
> >
> > On Wed, Aug 19, 2015 at 9:25 PM, Manikumar Reddy
> > wrote:
> >
> > > Hi,
> > >
> > > We have raised a Apache Infra ticket for mi
Also can we migrate svn repo to git repo? This will help us to fix
occasional doc changes/bug fixes through github PR.
On Thu, Aug 20, 2015 at 4:04 AM, Guozhang Wang wrote:
> Gwen: I remembered it wrong. We would not need another round of voting.
>
> On Wed, Aug 19, 2015 at 3:06 PM, Gwen Shap
Hi All,
Can we finalize the approach? So that we can proceed further.
1. Gwen's suggestion + existing svn repo
2. Gwen's suggestion + new git repo for docs
kumar
On Thu, Aug 20, 2015 at 11:48 PM, Manikumar Reddy
wrote:
> Also can we migrate svn repo to git repo? This will h
nt to clone the repo for the generated site, we can
> use the same tools as we do for the code repo and we can watch for changes
> on GitHub, etc.
>
> Ismael
>
> On Fri, Aug 21, 2015 at 1:34 PM, Manikumar Reddy
> wrote:
>
> > Hi All,
> >
> > Can we finalize th
//git-wip-us.apache.org/repos/asf/kafka-site.git
Hope this clears the confusion.
Kumar
I thought Gwen's suggestion was to us a separate folder in the same repo
for docs instead of a separate branch, Gwen can correct me if I was wrong?
Guozhang
On Mon, Aug 24, 2015 at 10:31 AM, Manikumar Reddy
Hi Kafka Devs,
Current svn website has the following directory structure.
082/
083/
code.html
coding-guide.html
committers.html
contact.html
contributing.html
diagrams/
documentation.html
downloads.html
images
includes/
index.html
I will be coping
During server/client startup, we are logging all the supplied configs. May
be we can just mask
the password related config values for both valid/invalid configs.
On Wed, Aug 17, 2016 at 5:14 PM, Jaikiran Pai
wrote:
> Any opinion about this proposed change?
>
> -Jaikiran
>
> On Tuesday 16 August
+1 (non-binding)
This feature help us control memory footprint and allows consumer to
progress on fetching large messages.
On Fri, Aug 19, 2016 at 10:32 AM, Gwen Shapira wrote:
> +1 (binding)
>
> On Thu, Aug 18, 2016 at 1:47 PM, Andrey L. Neporada
> wrote:
> > Hi all!
> > I’ve modified KIP-74
We don't need JIRA for minor PRs. Just prefix "MINOR:" to PR title.
On Tue, Sep 6, 2016 at 9:16 AM, Jaikiran Pai
wrote:
> Thanks Ismael, I'll raise a PR for this. As a process, is there a JIRA
> that's expected to be filed for this before I raise a PR or would this be
> OK without a JIRA?
>
> -J
Hi,
Kafka uses "test" as classifier (default is "tests" ) for test jars.
We can add test parameter to dependency tag to
resolve the error.
org.apache.kafka
kafka-streams
0.10.0.0
test-jar
test
Thanks
Manikumar
On Tue, Sep
adding missing classifier parameter..
org.apache.kafka
kafka-streams
0.10.0.0
test-jar
test
On Tue, Sep 13, 2016 at 12:07 PM, Manikumar Reddy wrote:
> Hi,
>
> Kafka uses "test" as classifier (default is "tests" ) for test jars.
> We can add test paramete
us.apache.org/repos/asf/kafka-site.git
Kumar
On Wed, Aug 26, 2015 at 7:43 PM, Manikumar Reddy
wrote:
> Hi Guozhang,
>
> Our plan is to follow Gwen's suggested approach and migrate the existing
> svn site repo to new git repo.
>
> (1) Gwen's suggestion will help
+1 (non-binding). verified the artifacts, quick start.
On Wed, Sep 9, 2015 at 2:41 AM, Ashish wrote:
> +1 (non-binding)
>
> Ran the build, works fine. All test cases passed
>
> On Thu, Sep 3, 2015 at 9:22 AM, Jun Rao wrote:
> > This is the first candidate for release of Apache Kafka 0.8.2.2. Th
w repository? it looks
> like you already got a new repository, so why do we need a branch as well?
>
>
>
> On Wed, Sep 2, 2015 at 8:11 AM, Manikumar Reddy
> wrote:
>
> > Jun/Gwen/Guozhang,
> >Need your help to complete this.
> >
> > (1) Copy latest d
congrats harsha!
On Tue, Sep 22, 2015 at 9:48 AM, Dong Lin wrote:
> Congratulations Sriharsha!
>
> Dong
>
> On Tue, Sep 22, 2015 at 4:17 AM, Guozhang Wang wrote:
>
> > Congrats Sriharsha!
> >
> > Guozhang
> >
> > On Mon, Sep 21, 2015 at 9:10 PM, Jun Rao wrote:
> >
> > > I am pleased to announc
to show this in our website?
>
> Next steps:
> 1) Minor fix to PR 171
> 2) Merge PR 171
> 3) Get Apache to show our git site
> 4) Update wiki with "contributing to docs" process
>
> Gwen
>
>
>
> On Tue, Sep 15, 2015 at 8:40 AM, Manikumar Reddy
> wrote:
>
th infra on our github site
> 2. Update the docs contribution guide
> 3. Update the release guide (since we are releasing docs as part of our
> release artifacts)
>
> Mani, I assume you are on those?
> Anything I'm missing?
>
> Gwen
>
> On Fri, Oct 2, 2015 at 11:28 P
Hi Gwen,
Kafka site is updated to use Git repo. We can now push any site changes to
git web site repo.
1) "Contributing website changes" wiki page:
https://cwiki.apache.org/confluence/display/KAFKA/Contributing+Website+Documentation+Changes
2) "Website update process" added to Release Process wi
mand used to do this as well?
>
Yes, updated the wiki page.
>
> Ismael
>
> On Tue, Oct 6, 2015 at 3:37 AM, Manikumar Reddy
> wrote:
>
> > Hi Gwen,
> >
> > Kafka site is updated to use Git repo. We can now push any site changes
> to
> > git web site rep
Hi,
I see a single partition for the newly created topic, and it has
> only one replica. Is there a way to specify a replication factor greater
> than 1?
>
you can set default.replication.factor config property, This property is
used to
set default replication factor for auto created topics.
+1 (non-binding). Verified the source and binary releases.
Regards,
Manikumar
Congrats!
On Thu, Nov 20, 2014 at 8:04 AM, Jun Rao wrote:
> Guozhang,
>
> Congratulations! Thanks a lot for all your work.
>
> Jun
>
> On Wed, Nov 19, 2014 at 4:05 PM, Neha Narkhede
> wrote:
>
> > Hi everyone,
> >
> > I'm very happy to announce that the Kafka PMC has invited Guozhang Wang
> to
+1 for this change.
what about de-serializer class in 0.8.2? Say i am using new producer with
Avro and old consumer combination.
then i need to give custom Decoder implementation for Avro right?.
On Tue, Nov 25, 2014 at 9:19 PM, Joe Stein wrote:
> The serializer is an expected use of the prod
[
https://issues.apache.org/jira/browse/KAFKA-2159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-2159:
---
Resolution: Duplicate
Status: Resolved (was: Patch Available
[
https://issues.apache.org/jira/browse/KAFKA-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-2800:
---
Status: Reopened (was: Closed)
> Update outdated dependenc
[
https://issues.apache.org/jira/browse/KAFKA-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy resolved KAFKA-2800.
Resolution: Fixed
> Update outdated dependenc
[
https://issues.apache.org/jira/browse/KAFKA-3219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-3219:
---
Status: Reopened (was: Closed)
> Long topic names mess up broker topic st
[
https://issues.apache.org/jira/browse/KAFKA-3219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy resolved KAFKA-3219.
Resolution: Fixed
> Long topic names mess up broker topic st
[
https://issues.apache.org/jira/browse/KAFKA-2547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-2547:
---
Status: Reopened (was: Closed)
> Make DynamicConfigManager to use
[
https://issues.apache.org/jira/browse/KAFKA-2547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy resolved KAFKA-2547.
Resolution: Fixed
> Make DynamicConfigManager to use the ZkNodeChangeNotificationListe
[
https://issues.apache.org/jira/browse/KAFKA-2651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-2651:
---
Fix Version/s: 0.11.0.0
> Remove deprecated config alteration from TopicCommand in 0.9.
[
https://issues.apache.org/jira/browse/KAFKA-3802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-3802:
---
Status: Patch Available (was: Open)
> log mtimes reset on broker rest
[
https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-3950:
---
consumer.subscribe(Pattern p , ..) method is failing when authorizer is enabled.
irrespective of
[
https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15373115#comment-15373115
]
Manikumar Reddy commented on KAFKA-3950:
I was also thinking similar l
[
https://issues.apache.org/jira/browse/KAFKA-3961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15375342#comment-15375342
]
Manikumar Reddy commented on KAFKA-3961:
you can try DumpLogSegments tools t
[
https://issues.apache.org/jira/browse/KAFKA-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy resolved KAFKA-3102.
Resolution: Duplicate
> Kafka server unable to connect to zookee
[
https://issues.apache.org/jira/browse/KAFKA-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379135#comment-15379135
]
Manikumar Reddy commented on KAFKA-3102:
[~liuxinjian] There is no kafka i
[
https://issues.apache.org/jira/browse/KAFKA-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-2213:
---
Resolution: Duplicate
Status: Resolved (was: Patch Available)
This duplicate of
[
https://issues.apache.org/jira/browse/KAFKA-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15379198#comment-15379198
]
Manikumar Reddy commented on KAFKA-3102:
Subscribe to user mailing
[
https://issues.apache.org/jira/browse/KAFKA-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387174#comment-15387174
]
Manikumar Reddy commented on KAFKA-3980:
This may due to increasing in cl
[
https://issues.apache.org/jira/browse/KAFKA-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15390792#comment-15390792
]
Manikumar Reddy commented on KAFKA-3980:
[~ajorgensen] Can you enable debug
[
https://issues.apache.org/jira/browse/KAFKA-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15390792#comment-15390792
]
Manikumar Reddy edited comment on KAFKA-3980 at 7/23/16 6:2
[
https://issues.apache.org/jira/browse/KAFKA-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15393962#comment-15393962
]
Manikumar Reddy commented on KAFKA-3992:
looks like you are giving same clien
[
https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15399444#comment-15399444
]
Manikumar Reddy commented on KAFKA-3950:
[~ijuma] Can we include this in 0.10
[
https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-3950:
---
Affects Version/s: 0.10.0.0
> kafka mirror maker tool is not respecting whitelist opt
[
https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-3950:
---
Reviewer: Ismael Juma
Fix Version/s: 0.10.0.1
> kafka mirror maker tool is
[
https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-3950:
---
Affects Version/s: (was: 0.10.0.0)
0.9.0.0
> kafka mirror ma
[
https://issues.apache.org/jira/browse/KAFKA-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy resolved KAFKA-1612.
Resolution: Won't Fix
Closing this issue in favor new consumer API.
> Consumer
[
https://issues.apache.org/jira/browse/KAFKA-1884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14501112#comment-14501112
]
Manikumar Reddy commented on KAFKA-1884:
[~guozhang] can you review this tri
Manikumar Reddy created KAFKA-2131:
--
Summary: Update new producer javadocs with correct documentation
links
Key: KAFKA-2131
URL: https://issues.apache.org/jira/browse/KAFKA-2131
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-2131:
---
Description: New producer java docs are referring to old producer
documentation.
> Upd
[
https://issues.apache.org/jira/browse/KAFKA-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-2131:
---
Status: Patch Available (was: Open)
> Update new producer javadocs with corr
[
https://issues.apache.org/jira/browse/KAFKA-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14501144#comment-14501144
]
Manikumar Reddy commented on KAFKA-2131:
Created reviewboard h
/producer/ProducerConfig.java
ca1c7fedbde7f53d64426da3a1aa3aeeafd2e9ad
Diff: https://reviews.apache.org/r/4/diff/
Testing
---
Thanks,
Manikumar Reddy O
[
https://issues.apache.org/jira/browse/KAFKA-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-2131:
---
Attachment: KAFKA-2131.patch
> Update new producer javadocs with correct documentation li
[
https://issues.apache.org/jira/browse/KAFKA-1581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14501228#comment-14501228
]
Manikumar Reddy commented on KAFKA-1581:
[~jjkoshy] I think this can be cl
[
https://issues.apache.org/jira/browse/KAFKA-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14501295#comment-14501295
]
Manikumar Reddy commented on KAFKA-1758:
[~jkreps] Can I get review for
/diff/
Testing
---
Thanks,
Manikumar Reddy O
[
https://issues.apache.org/jira/browse/KAFKA-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14536267#comment-14536267
]
Manikumar Reddy commented on KAFKA-1758:
Updated reviewboard h
[
https://issues.apache.org/jira/browse/KAFKA-1758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-1758:
---
Attachment: KAFKA-1758_2015-05-09_12:29:20.patch
> corrupt recovery file prevents star
tException?
> > Seems like a fix that applies to all errors.
> >
> > Also, worth changing the error message to a more generic statement
> > about the problem and the fix (resetting the recovery checkpoint to 0).
Yes, we can catch other exce
data produced, 1136608 rows of data consumed (88.6% reduction).
De-duplicating and validating output files...
Validated 899853 values, 0 mismatches.
Thanks,
Manikumar Reddy O
It would be preferable to avoid
> > having this compression logic in different places.
moved the compresssMessages() method to ByteBufferMessageSet class. Pl let me
know your thoughts..
- Manikumar Reddy
[
https://issues.apache.org/jira/browse/KAFKA-1374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-1374:
---
Attachment: KAFKA-1374_2015-05-18_22:55:48.patch
> LogCleaner (compaction) does not supp
[
https://issues.apache.org/jira/browse/KAFKA-1374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14548354#comment-14548354
]
Manikumar Reddy commented on KAFKA-1374:
Updated reviewboard h
---
Thanks,
Manikumar Reddy O
[
https://issues.apache.org/jira/browse/KAFKA-2198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-2198:
---
Assignee: Manikumar Reddy
Status: Patch Available (was: Open)
> kafka-topics.sh ex
[
https://issues.apache.org/jira/browse/KAFKA-2198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-2198:
---
Attachment: KAFKA-2198.patch
> kafka-topics.sh exits with 0 status on failu
[
https://issues.apache.org/jira/browse/KAFKA-2198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550100#comment-14550100
]
Manikumar Reddy commented on KAFKA-2198:
Created reviewboard h
[
https://issues.apache.org/jira/browse/KAFKA-2198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550120#comment-14550120
]
Manikumar Reddy commented on KAFKA-2198:
Case 1: Zookeeper chroot pat
[
https://issues.apache.org/jira/browse/KAFKA-2134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14550190#comment-14550190
]
Manikumar Reddy commented on KAFKA-2134:
metricChange() method will be ca
://reviews.apache.org/r/34403/diff/
Testing
---
Thanks,
Manikumar Reddy O
1 - 100 of 872 matches
Mail list logo
