[
https://issues.apache.org/jira/browse/KAFKA-732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-732:
--
Affects Version/s: 0.8
> MirrorMaker with shallow.iterator.enable=true produces unreadble messages
> ---
[
https://issues.apache.org/jira/browse/KAFKA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-772.
---
Resolution: Fixed
Fix Version/s: 0.8
Thanks for the patch. Committed to 0.8.
> System
[
https://issues.apache.org/jira/browse/KAFKA-739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13593123#comment-13593123
]
Sriram Subramanian commented on KAFKA-739:
--
I am not able to apply this patch usin
[
https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592900#comment-13592900
]
Scott Carey commented on KAFKA-717:
---
I take that back, scala.annotation.StaticAnnotation
[
https://issues.apache.org/jira/browse/KAFKA-778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-778:
Labels: kafka-0.8 (was: )
> Fix unclear exceptions when the producer detects 0 partitions for a
[
https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592884#comment-13592884
]
Neha Narkhede commented on KAFKA-513:
-
Thanks for the patch! This patch is great and is
[
https://issues.apache.org/jira/browse/KAFKA-786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-786:
---
Assignee: Swapnil Ghike
> Use "withRequiredArg" while parsing jopt options in all tools
>
[
https://issues.apache.org/jira/browse/KAFKA-554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592883#comment-13592883
]
Jay Kreps commented on KAFKA-554:
-
Yeah I thought about json vs properties. The advantage i
[
https://issues.apache.org/jira/browse/KAFKA-786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-786:
Attachment: kafka-786.patch
Attached a patch.
> Use "withRequiredArg" while parsing
[
https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-785:
---
Assignee: Swapnil Ghike (was: Sriram Subramanian)
> Resolve bugs in PreferredReplicaLeade
[
https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-785:
---
Assignee: Sriram Subramanian (was: Swapnil Ghike)
> Resolve bugs in PreferredReplicaLeade
[
https://issues.apache.org/jira/browse/KAFKA-786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592863#comment-13592863
]
Swapnil Ghike edited comment on KAFKA-786 at 3/5/13 12:46 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592863#comment-13592863
]
Swapnil Ghike commented on KAFKA-786:
-
Also note that withRequiredArg() does not check
[
https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592862#comment-13592862
]
Scott Carey commented on KAFKA-717:
---
It appears that the changes are back-compatible with
Swapnil Ghike created KAFKA-786:
---
Summary: Use "withRequiredArg" while parsing jopt options in all
tools
Key: KAFKA-786
URL: https://issues.apache.org/jira/browse/KAFKA-786
Project: Kafka
Issu
[
https://issues.apache.org/jira/browse/KAFKA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592850#comment-13592850
]
Sriram Subramanian commented on KAFKA-772:
--
The test failed on Monday and then aga
[
https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592844#comment-13592844
]
Swapnil Ghike commented on KAFKA-785:
-
Well, you avoid a small jump in logic (jsonFile
[
https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592841#comment-13592841
]
Sriram Subramanian commented on KAFKA-785:
--
It does not simplify anything though.
[
https://issues.apache.org/jira/browse/KAFKA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592839#comment-13592839
]
Sriram Subramanian commented on KAFKA-772:
--
I would like WARN to be actionable. Do
[
https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592837#comment-13592837
]
Swapnil Ghike commented on KAFKA-785:
-
Can we use val jsonString = if (options.has(json
[
https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592834#comment-13592834
]
Darren Sargent commented on KAFKA-717:
--
I got Kafka 0.8 to compile and run with Scala
[
https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sriram Subramanian updated KAFKA-785:
-
Attachment: KAFKA-785.patch
1. Made partition input file optional for PreferredReplicaLead
[
https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Darren Sargent updated KAFKA-717:
-
Attachment: kafka_scala_2.10.tar.gz
> scala 2.10 build support
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-780:
Issue Type: Sub-task (was: Bug)
Parent: KAFKA-785
> Reassign partitions tool produces N
[
https://issues.apache.org/jira/browse/KAFKA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592826#comment-13592826
]
Neha Narkhede commented on KAFKA-772:
-
It would be useful to maybe add a WARN message a
[
https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-785:
---
Assignee: Sriram Subramanian (was: Swapnil Ghike)
> Resolve bugs in PreferredReplicaLeade
[
https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-785:
Description:
1. Since we run the preferred replica election on all partitions if the
jsonFile is em
[
https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-785:
Summary: Resolve bugs in PreferredReplicaLeaderElection admin tool (was:
jsonFileOpt in PreferredRe
[
https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-785:
---
Assignee: Swapnil Ghike (was: Sriram Subramanian)
> jsonFileOpt in PreferredReplicaLeader
[
https://issues.apache.org/jira/browse/KAFKA-741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-741.
-
Resolution: Duplicate
This issue is fixed in the patch for KAFKA-739. It removes the duplication
using a
[
https://issues.apache.org/jira/browse/KAFKA-780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-780:
---
Assignee: Sriram Subramanian
> Reassign partitions tool produces NPE in shutdown handler
>
[
https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike reassigned KAFKA-785:
---
Assignee: Sriram Subramanian (was: Swapnil Ghike)
> jsonFileOpt in PreferredReplicaLeader
[
https://issues.apache.org/jira/browse/KAFKA-739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-739:
Attachment: KAFKA-739-v1.patch
This patch is more extensive than I expected because I found a hole in the
l
[
https://issues.apache.org/jira/browse/KAFKA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sriram Subramanian updated KAFKA-772:
-
Attachment: KAFKA-772.patch
> System Test Transient Failure on testcase_0122
> ---
Swapnil Ghike created KAFKA-785:
---
Summary: jsonFileOpt in PreferredReplicaLeaderElectionTool should
not be "required"
Key: KAFKA-785
URL: https://issues.apache.org/jira/browse/KAFKA-785
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-779:
Attachment: kafka-779-v2.patch
Modified the description of the --path-to-json-file option required b
[
https://issues.apache.org/jira/browse/KAFKA-763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-763:
Labels: kafka-0.8 p2 (was: p2)
> Add an option to replica from the largest offset during unclea
[
https://issues.apache.org/jira/browse/KAFKA-783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592566#comment-13592566
]
Chris Curtin commented on KAFKA-783:
Confirmed same behavior on 0.8.0 HEAD as of 3/4/20
[
https://issues.apache.org/jira/browse/KAFKA-782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592565#comment-13592565
]
Chris Curtin commented on KAFKA-782:
Confirmed same behavior with 0.8.0 HEAD as of 3/4/
Chris Curtin created KAFKA-784:
--
Summary: creating topic without partitions, deleting then creating
with partition causes errors in 'kafka-list-topic'
Key: KAFKA-784
URL: https://issues.apache.org/jira/browse/KAFKA-7
Issue Subscription
Filter: outstanding kafka patches (58 issues)
The list of outstanding kafka patches
Subscriber: kafka-mailing-list
Key Summary
KAFKA-779 Standardize Zk data structures for Re-assign partitions and
Preferred replication election
https://issues.apach
Chris Curtin created KAFKA-783:
--
Summary: Preferred replica assignment on leader failure may not be
correct
Key: KAFKA-783
URL: https://issues.apache.org/jira/browse/KAFKA-783
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-97?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-97.
--
Resolution: Not A Problem
Fix Version/s: 0.8
> SocketServer.scala refers to Handler-specific variables
Chris Curtin created KAFKA-782:
--
Summary: replicas not being displayed in TopicMetadataResponse
when replica's Broker is shutdown
Key: KAFKA-782
URL: https://issues.apache.org/jira/browse/KAFKA-782
Proje
[
https://issues.apache.org/jira/browse/KAFKA-97?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-97 started by Jun Rao.
> SocketServer.scala refers to Handler-specific variables
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-97?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-97.
> SocketServer.scala refers to Handler-specific variables
> ---
>
[
https://issues.apache.org/jira/browse/KAFKA-97?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592405#comment-13592405
]
Colin B. commented on KAFKA-97:
---
The code referenced no longer exists in 0.8. On quick inspect
[
https://issues.apache.org/jira/browse/KAFKA-105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592396#comment-13592396
]
Colin B. commented on KAFKA-105:
It appears that due to lack of discussion this bug should
Neha Narkhede created KAFKA-781:
---
Summary: Add option to the controlled shutdown tool to timeout
after n secs
Key: KAFKA-781
URL: https://issues.apache.org/jira/browse/KAFKA-781
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-135.
-
Assignee: Pierre-Yves Ritschard
> the ruby kafka gem is not functional
>
[
https://issues.apache.org/jira/browse/KAFKA-123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-123.
---
Resolution: Duplicate
Fix Version/s: 0.7
> Rubygem gemspec doesn't build correctly
> --
[
https://issues.apache.org/jira/browse/KAFKA-123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao closed KAFKA-123.
-
> Rubygem gemspec doesn't build correctly
> ---
>
> Key: KAFKA
Matan,
Thanks for picking this up. Yes, this is likely a post 0.8 item and should
go into trunk. Could you file a jira and post your initial design there for
discussion?
Jun
On Sat, Mar 2, 2013 at 12:53 PM, matan wrote:
> Hi,
>
> I am designing a patch on top the 0.8 code base.
> The patch wou
Jonathan,
My understanding is that channel is a local concept in Flume. So, are you
using a single local Kafka broker to build channel? Will it make more sense
to build a Kafka sink in Fume?
Thanks,
Jun
On Fri, Mar 1, 2013 at 10:56 PM, Jonathan Creasy wrote:
> I started hacking on a Kafka Cha
[
https://issues.apache.org/jira/browse/KAFKA-123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13592352#comment-13592352
]
Colin B. commented on KAFKA-123:
This was a duplicate of Kafka-135 and is already fixed. Pl
55 matches
Mail list logo
