Swapnil Ghike created KAFKA-1006:
Summary: Mirror maker loses messages of a new topic
Key: KAFKA-1006
URL: https://issues.apache.org/jira/browse/KAFKA-1006
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13734903#comment-13734903
]
Jun Rao commented on KAFKA-992:
---
Thanks for the patch. It doesn't seem to apply for me. Do yo
[
https://issues.apache.org/jira/browse/KAFKA-347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13734908#comment-13734908
]
Jun Rao commented on KAFKA-347:
---
You just need to run bin/kafka-add-partitions.sh. We will ad
Sriram Subramanian created KAFKA-1007:
-
Summary: Document new tools before 0.8 release
Key: KAFKA-1007
URL: https://issues.apache.org/jira/browse/KAFKA-1007
Project: Kafka
Issue Type: Bug
Dibyendu,
According to the pull request: https://github.com/linkedin/camus/pull/15 it
was merged into the camus-kafka-0.8 branch. I have not checked if the code
was subsequently removed, however, two at least one the important files
from this patch
(camus-api/src/main/java/com/linkedin/camus/etl/Re
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13734994#comment-13734994
]
Guozhang Wang commented on KAFKA-992:
-
Thanks for the comments Jun. I think the re-regi
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13734999#comment-13734999
]
Neha Narkhede commented on KAFKA-992:
-
I agree with Guozhang that the logic to ensure w
[
https://issues.apache.org/jira/browse/KAFKA-990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13735120#comment-13735120
]
Joel Koshy commented on KAFKA-990:
--
Can you elaborate on the change to shutdownBroker in K
I just checked and that patch is in .8 branch. Thanks for working on back
porting it Andrew. We'd be happy to commit that work to master.
As for the kafka contrib project vs Camus, they are similar but not quite
identical. Camus is intended to be a high throughput ETL for bulk
ingestion of Kaf
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-992:
Attachment: KAFKA-992.v8.patch
Incremental patch uploaded. Fixed a small issue that Json.parse will
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13735437#comment-13735437
]
Neha Narkhede commented on KAFKA-992:
-
+1 on v8. Good catch!
> Double
[
https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede closed KAFKA-992.
---
> Double Check on Broker Registration to Avoid False NodeExist Exception
> ---
[
https://issues.apache.org/jira/browse/KAFKA-990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13735653#comment-13735653
]
Joel Koshy commented on KAFKA-990:
--
Looks like I might have looked at the wrong patch. I'l
Hi Ken,
I am also working on making the Camus fit for Non Avro message for our
requirement.
I see you mentioned about this patch
(https://github.com/linkedin/camus/commit/87917a2aea46da9d21c8f67129f6463af52f7aa8)
which supports custom data writer for Camus. But this patch is not pulled into
14 matches
Mail list logo
