[
https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660269#comment-14660269
]
Jason Gustafson commented on KAFKA-2397:
[~jkreps] Yeah, TCP is pretty resilient
[
https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660276#comment-14660276
]
Mayuresh Gharat commented on KAFKA-2120:
[~jasong35] I am not too familiar with
[
https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660279#comment-14660279
]
Jay Kreps commented on KAFKA-2397:
--
[~guozhang] Basically session would be the concept
+1 for the same repo. The closer docs can be to code the more accurate they
are likely to be. The same way we encourage unit tests for a new
feature/patch. Updating the docs can be the same.
If we follow Sqoop's process for example, how would small
fixes/adjustments/additions to the live
[
https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660717#comment-14660717
]
Jason Gustafson commented on KAFKA-1893:
Ditto what [~onurkaraman] said. I think
Github user asfgit closed the pull request at:
https://github.com/apache/kafka/pull/116
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/KAFKA-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-2400:
-
Resolution: Fixed
Fix Version/s: 0.8.3
Status: Resolved (was: Patch Available)
[
https://issues.apache.org/jira/browse/KAFKA-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660810#comment-14660810
]
ASF GitHub Bot commented on KAFKA-2400:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660687#comment-14660687
]
Onur Karaman commented on KAFKA-1893:
-
I agree with [~singhashish] that we should keep
[
https://issues.apache.org/jira/browse/KAFKA-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660896#comment-14660896
]
Onur Karaman commented on KAFKA-2400:
-
It seems that this change could increase the
I am +1 on same repo too. I think keeping one git history of code / doc
change may actually be beneficial for this approach as well.
Guozhang
On Thu, Aug 6, 2015 at 9:16 AM, Gwen Shapira g...@confluent.io wrote:
I prefer same repo for one-commit / lower-barrier benefits.
Sqoop has the
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661246#comment-14661246
]
Onur Karaman commented on KAFKA-2413:
-
I'll have the patch ready later today.
New
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661294#comment-14661294
]
Ashish K Singh commented on KAFKA-2413:
---
Hi [~onurkaraman], sorry for not explicitly
[
https://issues.apache.org/jira/browse/KAFKA-2415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661255#comment-14661255
]
ASF GitHub Bot commented on KAFKA-2415:
---
GitHub user becketqin opened a pull
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661317#comment-14661317
]
ASF GitHub Bot commented on KAFKA-2413:
---
GitHub user onurkaraman opened a pull
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661319#comment-14661319
]
Onur Karaman commented on KAFKA-2413:
-
Aand I just saw this. My bad.
New
[
https://issues.apache.org/jira/browse/KAFKA-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661253#comment-14661253
]
Jiangjie Qin commented on KAFKA-1997:
-
Oh... I forgot to do it when integrating the
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661329#comment-14661329
]
Ashish K Singh commented on KAFKA-2413:
---
I am not sure if posting patches to issues
[
https://issues.apache.org/jira/browse/KAFKA-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661250#comment-14661250
]
ASF GitHub Bot commented on KAFKA-1997:
---
GitHub user becketqin opened a pull
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661227#comment-14661227
]
Onur Karaman edited comment on KAFKA-2413 at 8/7/15 2:51 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661227#comment-14661227
]
Onur Karaman commented on KAFKA-2413:
-
Woops! I haven't tried it out yet, but I think
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661227#comment-14661227
]
Onur Karaman edited comment on KAFKA-2413 at 8/7/15 2:51 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661242#comment-14661242
]
Onur Karaman commented on KAFKA-2413:
-
Okay I just tested it out. It seems to have
Jiangjie Qin created KAFKA-2415:
---
Summary: Transient failure in
LogRecoveryTest.testHWCheckpointWithFailuresMultipleLogSegments
Key: KAFKA-2415
URL: https://issues.apache.org/jira/browse/KAFKA-2415
GitHub user hachikuji opened a pull request:
https://github.com/apache/kafka/pull/119
KAFKA-2403; Add support for commit metadata in KafkaConsumer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/hachikuji/kafka KAFKA-2403
[
https://issues.apache.org/jira/browse/KAFKA-2403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660911#comment-14660911
]
Jason Gustafson commented on KAFKA-2403:
No hurry to get this checked in, but I
[
https://issues.apache.org/jira/browse/KAFKA-2403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660909#comment-14660909
]
ASF GitHub Bot commented on KAFKA-2403:
---
GitHub user hachikuji opened a pull
[
https://issues.apache.org/jira/browse/KAFKA-2403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-2403:
---
Status: Patch Available (was: Open)
Expose offset commit metadata in new consumer
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661094#comment-14661094
]
Ashish K Singh commented on KAFKA-2413:
---
[~hachikuji] thoughts?
New consumer's
[
https://issues.apache.org/jira/browse/KAFKA-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-2351:
---
Status: In Progress (was: Patch Available)
Brokers are having a problem shutting down correctly
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661157#comment-14661157
]
Ashish K Singh commented on KAFKA-2413:
---
Thanks guys for quick response!
Below is a
[
https://issues.apache.org/jira/browse/KAFKA-2414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bo Wang updated KAFKA-2414:
---
Summary: Running kafka-producer-perf-test.sh with --messages 1000
--message-size 1000 --new-producer
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661177#comment-14661177
]
Ashish K Singh commented on KAFKA-2413:
---
[~hachikuji] I was planning to play with it
[
https://issues.apache.org/jira/browse/KAFKA-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660903#comment-14660903
]
Jason Gustafson commented on KAFKA-2400:
[~onurkaraman] The goal of the ticket was
[
https://issues.apache.org/jira/browse/KAFKA-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660921#comment-14660921
]
Guozhang Wang commented on KAFKA-2400:
--
Hey [~onurkaraman], yeah that is indeed an
Ashish K Singh created KAFKA-2413:
-
Summary: New consumer's subscribe(Topic...) api fails if called
more than once
Key: KAFKA-2413
URL: https://issues.apache.org/jira/browse/KAFKA-2413
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-1835:
---
Resolution: Fixed
Status: Resolved (was: Patch Available)
[~smiklosovic], I think this is being
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661135#comment-14661135
]
Jason Gustafson commented on KAFKA-2413:
[~onurkaraman] I was able to reproduce
[
https://issues.apache.org/jira/browse/KAFKA-2414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661164#comment-14661164
]
Bo Wang commented on KAFKA-2414:
The exception sometimes occurs , how can I fix or avoid
[
https://issues.apache.org/jira/browse/KAFKA-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660950#comment-14660950
]
Jason Gustafson commented on KAFKA-2400:
[~onurkaraman], [~guozhang] One related
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661160#comment-14661160
]
Jason Gustafson commented on KAFKA-2413:
I think the issue is in here:
{code}
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661160#comment-14661160
]
Jason Gustafson edited comment on KAFKA-2413 at 8/7/15 1:20 AM:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36858/#review94447
---
Thanks for the patch. A few comments below. Also, there seems to be
[
https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-2120:
---
Status: In Progress (was: Patch Available)
Add a request timeout to NetworkClient
[
https://issues.apache.org/jira/browse/KAFKA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-1835.
Resolution: Duplicate
Kafka new producer needs options to make blocking behavior explicit
[
https://issues.apache.org/jira/browse/KAFKA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao reopened KAFKA-1835:
Kafka new producer needs options to make blocking behavior explicit
Bo Wang created KAFKA-2414:
--
Summary: Running kafka-producer-perf-test.sh with --messages
1000 --message-size 1000 --new-producer will got WARN Error in I/O.
Key: KAFKA-2414
URL:
[
https://issues.apache.org/jira/browse/KAFKA-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660896#comment-14660896
]
Onur Karaman edited comment on KAFKA-2400 at 8/6/15 10:39 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-2340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reassigned KAFKA-2340:
Assignee: Jason Gustafson
Add additional unit tests for new consumer Fetcher
[
https://issues.apache.org/jira/browse/KAFKA-2340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660927#comment-14660927
]
ASF GitHub Bot commented on KAFKA-2340:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/KAFKA-2340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-2340.
--
Resolution: Fixed
Fix Version/s: 0.8.3
Issue resolved by pull request 112
[
https://issues.apache.org/jira/browse/KAFKA-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660955#comment-14660955
]
Onur Karaman commented on KAFKA-2400:
-
[~hachikuji]: Yeah the reason behind the
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661110#comment-14661110
]
Onur Karaman commented on KAFKA-2413:
-
Couple questions to start things off:
1. What
[
https://issues.apache.org/jira/browse/KAFKA-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661161#comment-14661161
]
Jun Rao commented on KAFKA-1997:
[~becket_qin], has this been fixed yet? Thanks,
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661167#comment-14661167
]
Jason Gustafson commented on KAFKA-2413:
[~singhashish] I can attempt a patch if
[
https://issues.apache.org/jira/browse/KAFKA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14659965#comment-14659965
]
Stefan Miklosovic commented on KAFKA-1835:
--
Any progres? It is weird there is no
[
https://issues.apache.org/jira/browse/KAFKA-2364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14659917#comment-14659917
]
Aseem Bansal commented on KAFKA-2364:
-
How do you reply to and get those emails?
[
https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660329#comment-14660329
]
Jason Gustafson commented on KAFKA-2120:
[~mgharat] Sounds reasonable to me.
[
https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660397#comment-14660397
]
Mayuresh Gharat commented on KAFKA-2120:
[~becket_qin] yes we can do that. I will
[
https://issues.apache.org/jira/browse/KAFKA-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660361#comment-14660361
]
Mayuresh Gharat commented on KAFKA-2351:
Thanks [~junrao]. I will see if I can
[
https://issues.apache.org/jira/browse/KAFKA-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660361#comment-14660361
]
Mayuresh Gharat edited comment on KAFKA-2351 at 8/6/15 5:11 PM:
[
https://issues.apache.org/jira/browse/KAFKA-2143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660629#comment-14660629
]
Ewen Cheslack-Postava commented on KAFKA-2143:
--
[~wushujames] I think one
[
https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660397#comment-14660397
]
Mayuresh Gharat edited comment on KAFKA-2120 at 8/6/15 5:24 PM:
[
https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660303#comment-14660303
]
Jason Gustafson commented on KAFKA-2120:
[~mgharat] Yeah, that's what I mean. I
[
https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660375#comment-14660375
]
Jiangjie Qin commented on KAFKA-2120:
-
[~hachikuji] [~mgharat], the request time is
[
https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660584#comment-14660584
]
Ashish K Singh commented on KAFKA-1893:
---
Should we support topic and regex
[
https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660314#comment-14660314
]
Mayuresh Gharat commented on KAFKA-2120:
Hi [~jasong35],
Cool. So what we can do
[
https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660405#comment-14660405
]
Jason Gustafson commented on KAFKA-2120:
[~becket_qin] That is what I was thinking
OK, the general consensus seems to be that more elaborate partitioning
functions belong to the scope of Kafka.
Could somebody have a look at KAFKA-2092
https://issues.apache.org/jira/browse/KAFKA-2092 then?
--
Gianmarco
On 30 July 2015 at 05:57, Jiangjie Qin j...@linkedin.com.invalid wrote:
[
https://issues.apache.org/jira/browse/KAFKA-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2411 started by Ismael Juma.
--
remove usage of BlockingChannel in the broker
[
https://issues.apache.org/jira/browse/KAFKA-2364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660041#comment-14660041
]
Ben Stopford commented on KAFKA-2364:
-
Hi Aseem
Have you signed up to the mailing
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34641/#review94378
---
core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala
Hi,
For reference, here is the previous discussion on moving the website to Git:
http://search-hadoop.com/m/uyzND11JliU1E8QU92
People were positive to the idea as Jay said. I would like to see a bit of
a discussion around whether the website should be part of the same repo as
the code or not.
[
https://issues.apache.org/jira/browse/KAFKA-2364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14659615#comment-14659615
]
Ismael Juma commented on KAFKA-2364:
[~anshbansal], there were a couple of responses:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33049/#review94412
---
A few more comments.
We need to be careful with sensors at the
I prefer same repo for one-commit / lower-barrier benefits.
Sqoop has the following process, which decouples documentation changes from
website changes:
1. Code github repo contains a doc directory, with the documentation
written and maintained in AsciiDoc. Only one version of the documentation,
[
https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660241#comment-14660241
]
Jason Gustafson commented on KAFKA-2120:
[~mgharat] It occurred to me that the
[
https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660242#comment-14660242
]
Glenn Sontheimer commented on KAFKA-2120:
-
Hello,
I am out of the office and will
78 matches
Mail list logo