Okay I have fixed all the problems people found that I am aware of:
1. Correlation id used throughout
2. Brokers in metadata api not repeated per-partition
3. Removed creator id from broker because it is silly
4. All versions baselined to 0 (both ApiVersions and the message "magic"
version)
5. Remo
[
https://issues.apache.org/jira/browse/KAFKA-374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13526171#comment-13526171
]
Jay Kreps commented on KAFKA-374:
-
Ooo very nice.
> Move to java CRC32 imp
[
https://issues.apache.org/jira/browse/KAFKA-374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13526136#comment-13526136
]
David Arthur commented on KAFKA-374:
I pulled in the pure-Java implementation from Hado
[
https://issues.apache.org/jira/browse/KAFKA-642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13526125#comment-13526125
]
Jay Kreps commented on KAFKA-642:
-
It also baselines all versions, including the message ma
[
https://issues.apache.org/jira/browse/KAFKA-642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-642:
Attachment: KAFKA-642-remove-response-versions.patch
This patch removes the response version. There was a di
Joel Koshy created KAFKA-661:
Summary: Prevent a shutting down broker from re-entering the ISR
Key: KAFKA-661
URL: https://issues.apache.org/jira/browse/KAFKA-661
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy closed KAFKA-633.
Checked into 0.8. Will file separate jira to protect the ISR from re-expansion.
> AdminTest.tes
[
https://issues.apache.org/jira/browse/KAFKA-633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy resolved KAFKA-633.
--
Resolution: Fixed
> AdminTest.testShutdownBroker fails
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13526028#comment-13526028
]
Jun Rao commented on KAFKA-633:
---
Thanks for the patch. +1.
> AdminTest.testS
[
https://issues.apache.org/jira/browse/KAFKA-633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-633:
-
Attachment: KAFKA-633-v1.patch
This is a timing issue that affects low-volume topics (and in this case an
[
https://issues.apache.org/jira/browse/KAFKA-660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-660:
Affects Version/s: (was: 0.8)
0.8.1
> Change (topic, partition) tuple
Swapnil Ghike created KAFKA-660:
---
Summary: Change (topic, partition) tuples to TopicAndPartition
Key: KAFKA-660
URL: https://issues.apache.org/jira/browse/KAFKA-660
Project: Kafka
Issue Type: B
[
https://issues.apache.org/jira/browse/KAFKA-654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13512081#comment-13512081
]
Neha Narkhede commented on KAFKA-654:
-
The bug is inside Log.truncateAndStartWithNewOff
Issue Subscription
Filter: outstanding kafka patches (54 issues)
The list of outstanding kafka patches
Subscriber: kafka-mailing-list
Key Summary
KAFKA-645 Create a shell script to run System Test with DEBUG details and
"tee" console output to a file
https://issues.a
[
https://issues.apache.org/jira/browse/KAFKA-201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy closed KAFKA-201.
> Support for mirroring from multiple sources
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy resolved KAFKA-201.
--
Resolution: Fixed
Yes - this should be addressed by MirrorMaker although the user should ensure
that th
Good point - fixed.
On Wed, Dec 5, 2012 at 9:22 PM, Jay Kreps wrote:
> Hey your wiki on mirror maker is very good. It doesn't actually say how to
> run it, though, does it?
>
> -Jay
>
[
https://issues.apache.org/jira/browse/KAFKA-654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13511601#comment-13511601
]
Jay Kreps commented on KAFKA-654:
-
I think this is almost certainly a bug in the log. I wil
[
https://issues.apache.org/jira/browse/KAFKA-654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13511579#comment-13511579
]
Joel Koshy commented on KAFKA-654:
--
FWIW, it should be easy to reproduce this - I just saw
[
https://issues.apache.org/jira/browse/KAFKA-330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-330:
Labels: features project (was: features)
> Add delete topic support
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13511573#comment-13511573
]
Jun Rao commented on KAFKA-631:
---
Prashanth,
Will you be interested in KAFKA-330 (delete topi
[
https://issues.apache.org/jira/browse/KAFKA-330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13511570#comment-13511570
]
Jun Rao commented on KAFKA-330:
---
The delete topic logic can follow the same logic in partitio
[
https://issues.apache.org/jira/browse/KAFKA-642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13511571#comment-13511571
]
Jay Kreps commented on KAFKA-642:
-
Ack, you're right.
> Protocol tweaks fo
[
https://issues.apache.org/jira/browse/KAFKA-642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13511549#comment-13511549
]
Jun Rao commented on KAFKA-642:
---
60. What you said makes sense. But from IDE, that call maps
A common question is what Kafka projects would be fun and aren't being
worked on by anyone else right now.
Most of the committers are working hard on getting 0.8 stable. So the most
useful thing anyone could do is download the 0.8 branch and bang on it
until it breaks and then help us track it dow
[
https://issues.apache.org/jira/browse/KAFKA-656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-656:
Labels: project (was: )
> Add Quotas to Kafka
> ---
>
> Key: KAFKA-656
[
https://issues.apache.org/jira/browse/KAFKA-657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-657:
Labels: project (was: )
> Add an API to commit offsets
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-559:
Labels: project (was: )
> Garbage collect old consumer metadata entries
> -
[
https://issues.apache.org/jira/browse/KAFKA-252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-252:
Labels: project (was: replication)
> Generalize getOffsetsBefore API to a new more general API getLeade
[
https://issues.apache.org/jira/browse/KAFKA-554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-554:
Labels: project (was: )
> Move all per-topic configuration into ZK and add to the CreateTopicCommand
>
[
https://issues.apache.org/jira/browse/KAFKA-266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-266:
Labels: project (was: )
> Kafka web console
> -
>
> Key: KAFKA-266
>
[
https://issues.apache.org/jira/browse/KAFKA-658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-658:
Labels: project (was: )
> Implement "Exact Mirroring" functionality in mirror maker
> -
[
https://issues.apache.org/jira/browse/KAFKA-560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-560:
Labels: project (was: )
> Garbage Collect obsolete topics
> ---
>
>
Jay Kreps created KAFKA-659:
---
Summary: Support request pipelining in the network server
Key: KAFKA-659
URL: https://issues.apache.org/jira/browse/KAFKA-659
Project: Kafka
Issue Type: New Feature
Jay Kreps created KAFKA-658:
---
Summary: Implement "Exact Mirroring" functionality in mirror maker
Key: KAFKA-658
URL: https://issues.apache.org/jira/browse/KAFKA-658
Project: Kafka
Issue Type: New F
[
https://issues.apache.org/jira/browse/KAFKA-554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-554:
Description:
We have a number of per-topic configurations that control message retention and
flush interval
[
https://issues.apache.org/jira/browse/KAFKA-252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-252:
Description:
The relevant discussion is here -
https://issues.apache.org/jira/browse/KAFKA-238?focusedComme
Jay Kreps created KAFKA-657:
---
Summary: Add an API to commit offsets
Key: KAFKA-657
URL: https://issues.apache.org/jira/browse/KAFKA-657
Project: Kafka
Issue Type: New Feature
Reporter:
Jay Kreps created KAFKA-656:
---
Summary: Add Quotas to Kafka
Key: KAFKA-656
URL: https://issues.apache.org/jira/browse/KAFKA-656
Project: Kafka
Issue Type: New Feature
Components: core
[
https://issues.apache.org/jira/browse/KAFKA-266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-266:
Summary: Kafka web console (was: Kafka web console design)
> Kafka web console
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-629.
-
Resolution: Duplicate
> Generalize the getOffsets call
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-223.
-
Resolution: Fixed
We have added an API like this in 0.8. It is described here:
https://cwiki.apache.org/c
[
https://issues.apache.org/jira/browse/KAFKA-271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-271.
-
Resolution: Fixed
Addressed this as part of KAFKA-642.
> Modify new FetchResponse object
[
https://issues.apache.org/jira/browse/KAFKA-271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps reassigned KAFKA-271:
---
Assignee: Jay Kreps
> Modify new FetchResponse object to remove the initial offset field
> ---
[
https://issues.apache.org/jira/browse/KAFKA-252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-252:
Priority: Major (was: Critical)
Description:
The relevant discussion is here -
https://issues.apach
[
https://issues.apache.org/jira/browse/KAFKA-642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13511489#comment-13511489
]
Jay Kreps commented on KAFKA-642:
-
60. This isn't an implict conversion. In java the method
[
https://issues.apache.org/jira/browse/KAFKA-595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-595:
Labels: feature (was: feature features)
Description:
In 0.7 Kafka always appended messages to the
[
https://issues.apache.org/jira/browse/KAFKA-595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-595:
Comment: was deleted
(was: I also think this should be a post 0.8 feature.)
> Decouple producer side co
[
https://issues.apache.org/jira/browse/KAFKA-595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-595:
Comment: was deleted
(was: I think saying it is unnecessary is perhaps overstating it. It depends
what you
[
https://issues.apache.org/jira/browse/KAFKA-328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-328:
Labels: newbie (was: )
> Write unit test for kafka server startup and shutdown API
> -
[
https://issues.apache.org/jira/browse/KAFKA-328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-328:
Description:
Background discussion in KAFKA-320
People often try to embed KafkaServer in an application tha
[
https://issues.apache.org/jira/browse/KAFKA-328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-328:
Summary: Write unit test for kafka server startup and shutdown API (was:
Improve kafka server startup and
[
https://issues.apache.org/jira/browse/KAFKA-631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13511430#comment-13511430
]
Prashanth Menon commented on KAFKA-631:
---
Sure, pass the ideas along onto the distribu
[
https://issues.apache.org/jira/browse/KAFKA-235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike resolved KAFKA-235.
-
Resolution: Fixed
Fix Version/s: 0.7.2
0.8
> Add a 'log.file.age' co
[
https://issues.apache.org/jira/browse/KAFKA-235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13511208#comment-13511208
]
Swapnil Ghike edited comment on KAFKA-235 at 12/6/12 7:59 AM:
--
55 matches
Mail list logo
