I think it makes sense to kill the hadoop consumer/producer code in Kafka,
given, as you said, Camus and the simplicity of the Hadoop producer.
/Sam
On Jul 2, 2013, at 5:01 PM, Jay Kreps jay.kr...@gmail.com wrote:
We currently have a contrib package for consuming and producing messages
from
If the Hadoop consumer/producers use-case will remain relevant for Kafka
(I assume it will), it would make sense to have the core components (kafka
input/output format at least) as part of Kafka so that it could be built,
tested and versioned together to maintain compatibility.
This would also
Vadim created KAFKA-958:
---
Summary: Please compile list of key metrics on the broker and
client side and put it on a wiki
Key: KAFKA-958
URL: https://issues.apache.org/jira/browse/KAFKA-958
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13699095#comment-13699095
]
Jay Kreps commented on KAFKA-943:
-
Yeah, I think the core disagreement is that we are
+1 on Jun's defn.
On Tue, Jul 2, 2013 at 10:21 PM, Jun Rao jun...@gmail.com wrote:
My vote is that a patch can go into 0.8 if (1) it fixes a critical issue or
(2) the change is trivial and it makes the 0.8 experience better (e.g.,
improving log4j readability). kafka-946 may fall into (2).
[
https://issues.apache.org/jira/browse/KAFKA-943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13699128#comment-13699128
]
Sam Meder commented on KAFKA-943:
-
So we also have a config management system external to
Sam,
Interested in taking a look at
KAFKA-959https://issues.apache.org/jira/browse/KAFKA-959
?
Thanks,
Jun
On Sun, Jun 23, 2013 at 11:01 PM, Sam Meder sam.me...@jivesoftware.comwrote:
Hey,
I now have roughly a day a week I can dedicate to working on Kafka, so I
am looking for issues in
Cosmin Lehene created KAFKA-960:
---
Summary: Upgrade Metrics to 3.x
Key: KAFKA-960
URL: https://issues.apache.org/jira/browse/KAFKA-960
Project: Kafka
Issue Type: Improvement
Affects
[
https://issues.apache.org/jira/browse/KAFKA-826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13699191#comment-13699191
]
Cosmin Lehene commented on KAFKA-826:
-
https://issues.apache.org/jira/browse/KAFKA-960
[
https://issues.apache.org/jira/browse/KAFKA-960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13699211#comment-13699211
]
Joel Koshy commented on KAFKA-960:
--
Given that there are API changes and mbean name
Jun,
Looks like the update would happen around here?
On Wed, Jul 3, 2013 at 12:53 PM, Jun Rao jun...@gmail.com wrote:
Sam,
Interested in taking a look at
KAFKA-959https://issues.apache.org/jira/browse/KAFKA-959
?
Thanks,
Jun
On Sun, Jun 23, 2013 at 11:01 PM, Sam Meder
https://github.com/apache/kafka/blob/0.8/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala#L152
On Wed, Jul 3, 2013 at 2:18 PM, S Ahmed sahmed1...@gmail.com wrote:
Jun,
Looks like the update would happen around here?
On Wed, Jul 3, 2013 at 12:53 PM, Jun Rao
[
https://issues.apache.org/jira/browse/KAFKA-957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-957:
Assignee: Guozhang Wang
MirrorMaker needs to preserve the key in the source cluster
Garrett Barton created KAFKA-961:
Summary: state.change.logger: Error on broker 1 while processing
LeaderAndIsr request correlationId 6 received from controller 1 epoch 1 for
partition (page_visits,0)
Key: KAFKA-961
[
https://issues.apache.org/jira/browse/KAFKA-960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13699389#comment-13699389
]
Cosmin Lehene commented on KAFKA-960:
-
[~jjkoshy] I was going to set it back on 3.x on
[
https://issues.apache.org/jira/browse/KAFKA-621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung resolved KAFKA-621.
-
Resolution: Fixed
Not an issue any more.
System Test 9051 : ConsoleConsumer doesn't
[
https://issues.apache.org/jira/browse/KAFKA-619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung closed KAFKA-619.
---
Regression : System Test 900x (Migration Tool) -
java.lang.ClassCastException: kafka.message.Message
[
https://issues.apache.org/jira/browse/KAFKA-624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung resolved KAFKA-624.
-
Resolution: Fixed
This is handled in KAFKA-882 KAFKA-883
Add 07 ConsoleConsumer to
[
https://issues.apache.org/jira/browse/KAFKA-606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung resolved KAFKA-606.
-
Resolution: Fixed
Not an issue any more.
System Test Transient Failure (case 0302 GC
[
https://issues.apache.org/jira/browse/KAFKA-606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung closed KAFKA-606.
---
System Test Transient Failure (case 0302 GC Pause) - Log segments mismatched
across replicas
[
https://issues.apache.org/jira/browse/KAFKA-607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung resolved KAFKA-607.
-
Resolution: Fixed
Not an issue any more.
System Test Transient Failure (case 4011 Log
[
https://issues.apache.org/jira/browse/KAFKA-607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung closed KAFKA-607.
---
System Test Transient Failure (case 4011 Log Retention) - ConsoleConsumer
receives less data
[
https://issues.apache.org/jira/browse/KAFKA-819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung closed KAFKA-819.
---
System Test : Add validation of log segment index to offset
[
https://issues.apache.org/jira/browse/KAFKA-792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung closed KAFKA-792.
---
Update multiple attributes in testcase__properties.json
[
https://issues.apache.org/jira/browse/KAFKA-716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung closed KAFKA-716.
---
SimpleConsumerPerformance does not consume all available messages
[
https://issues.apache.org/jira/browse/KAFKA-716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung resolved KAFKA-716.
-
Resolution: Fixed
Not an issue
SimpleConsumerPerformance does not consume all available
[
https://issues.apache.org/jira/browse/KAFKA-961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13699489#comment-13699489
]
Garrett Barton commented on KAFKA-961:
--
I found out what is going on. Since I'm doing
[
https://issues.apache.org/jira/browse/KAFKA-729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung resolved KAFKA-729.
-
Resolution: Fixed
Not an issue any more.
Gzip compression codec complains about missing
[
https://issues.apache.org/jira/browse/KAFKA-911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13699500#comment-13699500
]
Sriram Subramanian commented on KAFKA-911:
--
This has been fixed.
[
https://issues.apache.org/jira/browse/KAFKA-911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sriram Subramanian updated KAFKA-911:
-
Resolution: Fixed
Status: Resolved (was: Patch Available)
Bug in controlled
[
https://issues.apache.org/jira/browse/KAFKA-184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13699510#comment-13699510
]
Sriram Subramanian commented on KAFKA-184:
--
We have already fixed all the config
[
https://issues.apache.org/jira/browse/KAFKA-960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13699545#comment-13699545
]
Joel Koshy commented on KAFKA-960:
--
Not really. However, my point is that given that going
[
https://issues.apache.org/jira/browse/KAFKA-961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13699567#comment-13699567
]
Joel Koshy commented on KAFKA-961:
--
Passing in null for time would definitely lead to that
[
https://issues.apache.org/jira/browse/KAFKA-960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13699608#comment-13699608
]
Jay Kreps commented on KAFKA-960:
-
Word. I actually think given our experience we might be
Jakob Homan created KAFKA-962:
-
Summary: Add list topics to ClientUtils
Key: KAFKA-962
URL: https://issues.apache.org/jira/browse/KAFKA-962
Project: Kafka
Issue Type: Improvement
Affects
[
https://issues.apache.org/jira/browse/KAFKA-915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13699641#comment-13699641
]
Joel Koshy commented on KAFKA-915:
--
This failure is due to the fact that the leaderAndIsr
[
https://issues.apache.org/jira/browse/KAFKA-559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tejas Patil updated KAFKA-559:
--
Attachment: KAFKA-559.v1.patch
Attached KAFKA-559.v1.patch above.
- It has been developed to work do
[
https://issues.apache.org/jira/browse/KAFKA-961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13699741#comment-13699741
]
Garrett Barton commented on KAFKA-961:
--
Thanks for the reply! I personally lean
IMHO, I think Camus should probably be decoupled from Avro before the
simpler contribs are deleted.
We don't actually use the contribs, so I'm not saying this for our sake,
but it seems like the right thing to do to provide simple examples for this
type of stuff, no...?
--
Felix
On Wed, Jul 3,
Yes. We will need to think a bit more for the more general case when there
are messages for multiple topics.
Thanks,
Jun
On Wed, Jul 3, 2013 at 11:18 AM, S Ahmed sahmed1...@gmail.com wrote:
40 matches
Mail list logo