[
https://issues.apache.org/jira/browse/KAFKA-1954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sriharsha Chintalapani reassigned KAFKA-1954:
-
Assignee: Sriharsha Chintalapani
Speed Up The Unit Tests
[
https://issues.apache.org/jira/browse/KAFKA-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14396030#comment-14396030
]
Jay Kreps commented on KAFKA-1501:
--
[~gwenshap] I think the bounce tests in both the
[
https://issues.apache.org/jira/browse/KAFKA-2087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14396036#comment-14396036
]
Jay Kreps commented on KAFKA-2087:
--
[~aauradkar] this doesn't look like a javadoc
[
https://issues.apache.org/jira/browse/KAFKA-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14396022#comment-14396022
]
Gwen Shapira edited comment on KAFKA-1501 at 4/5/15 1:04 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-1631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14396039#comment-14396039
]
Jay Kreps commented on KAFKA-1631:
--
Is this behavior really so bad? I actually think
Thanks. I think I found a solution that doesn't take new locks or buffers:
1. Change the portProtocol map to ConcurrentHashMap (which makes it both
thread-safe and mutable). Initialize as empty map.
2. Initialize both processors and acceptors with the hashmap, also tell
each acceptor which
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/28769/
---
(Updated April 5, 2015, 5 a.m.)
Review request for kafka.
Bugs: KAFKA-1809
[
https://issues.apache.org/jira/browse/KAFKA-1809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14396071#comment-14396071
]
Gwen Shapira commented on KAFKA-1809:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira updated KAFKA-1809:
Attachment: KAFKA-1809_2015-04-04_22:00:13.patch
Refactor brokers to allow listening on multiple
Hi Gwen,
Can we buffer the requests that arrive before acceptors are up. Once we
have the acceptors, the buffer can be cleared. However, this adds on to the
complexity.
On Sunday, April 5, 2015, Gwen Shapira gshap...@cloudera.com wrote:
Hi,
I'm trying to rebase KAFKA-1809 after KAFKA-1501
[
https://issues.apache.org/jira/browse/KAFKA-1005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1005.
--
Resolution: Fixed
Committed.
kafka.perf.ConsumerPerformance not shutting down consumer
[
https://issues.apache.org/jira/browse/KAFKA-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14396053#comment-14396053
]
Gwen Shapira commented on KAFKA-1501:
-
woops. You are right [~jkreps], I overlooked
[
https://issues.apache.org/jira/browse/KAFKA-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14396022#comment-14396022
]
Gwen Shapira commented on KAFKA-1501:
-
Not to take from this awesome improvement, but
[
https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14396024#comment-14396024
]
Evan Huus commented on KAFKA-2082:
--
If the root of this bug is the controller not
See https://builds.apache.org/job/KafkaPreCommit/56/changes
[
https://issues.apache.org/jira/browse/KAFKA-1809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14396077#comment-14396077
]
Gwen Shapira commented on KAFKA-1809:
-
Quick summary of changes since [~jjkoshy] and
[
https://issues.apache.org/jira/browse/KAFKA-2087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14396083#comment-14396083
]
Aditya Auradkar commented on KAFKA-2087:
[~jkreps] Yeah, I've discarded that
[
https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14395847#comment-14395847
]
Evan Huus commented on KAFKA-2082:
--
Hmm, the test is configured to retry a message 5
[
https://issues.apache.org/jira/browse/KAFKA-1956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1956.
--
Resolution: Won't Fix
New consumer client can return early from a poll() call
[
https://issues.apache.org/jira/browse/KAFKA-1324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1324.
--
Resolution: Won't Fix
I think we can leave packaging out of Kafka itself since this is done in a
bunch
[
https://issues.apache.org/jira/browse/KAFKA-1049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1049.
--
Resolution: Won't Fix
Obsolete now that we have the new clients.
Encoder implementations are required
[
https://issues.apache.org/jira/browse/KAFKA-312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-312.
-
Resolution: Won't Fix
Add 'reset' operation for AsyncProducerDroppedEvents
[
https://issues.apache.org/jira/browse/KAFKA-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14395967#comment-14395967
]
Jay Kreps commented on KAFKA-1528:
--
[~evvers] is this still active?
Normalize all the
[
https://issues.apache.org/jira/browse/KAFKA-1904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14395968#comment-14395968
]
Jay Kreps commented on KAFKA-1904:
--
Is this still active?
run sanity failed test
[
https://issues.apache.org/jira/browse/KAFKA-2091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sriharsha Chintalapani reassigned KAFKA-2091:
-
Assignee: Sriharsha Chintalapani
Expose a Partitioner interface in the
[
https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14395970#comment-14395970
]
Jay Kreps commented on KAFKA-1351:
--
[~nehanarkhede] is this still active? If not can we
[
https://issues.apache.org/jira/browse/KAFKA-2050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-2050.
--
Resolution: Fixed
Reviewer: Jay Kreps
Assignee: Jay Kreps (was: Jun Rao)
Nice catch,
[
https://issues.apache.org/jira/browse/KAFKA-2002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-2002.
--
Resolution: Fixed
Reviewer: Jay Kreps
Assignee: Jay Kreps
Nice catch.
It does not work
[
https://issues.apache.org/jira/browse/KAFKA-1303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-1303.
Resolution: Won't Fix
I think this is less of an issue given that we have
[
https://issues.apache.org/jira/browse/KAFKA-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Evgeny Vereshchagin resolved KAFKA-1528.
Resolution: Not a Problem
No. You can close this ticket.
Normalize all the line
[
https://issues.apache.org/jira/browse/KAFKA-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14395979#comment-14395979
]
Evgeny Vereshchagin edited comment on KAFKA-1528 at 4/4/15 10:41 PM:
[
https://issues.apache.org/jira/browse/KAFKA-1054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14395980#comment-14395980
]
Jay Kreps commented on KAFKA-1054:
--
[~nehanarkhede] I think this is waiting on you.
[
https://issues.apache.org/jira/browse/KAFKA-1809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14395982#comment-14395982
]
Gwen Shapira commented on KAFKA-1809:
-
Ick. Looks like KAFKA-1501 was committed.
[
https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14395985#comment-14395985
]
Jun Rao commented on KAFKA-2082:
[~sriharsha], the reason why ReplicaFetcherManager
[
https://issues.apache.org/jira/browse/KAFKA-2024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-2024.
--
Resolution: Fixed
Reviewer: Jay Kreps
Nice catch and nice patch. Applied.
Cleaner can generate
Hey Aditya,
2. For the return flag I'm not terribly particular. If we want to add it
let's fully think through how it will be used. The only concern I have is
adding to the protocol without really thinking through the use cases. So
let's work out the APIs we want to add to the Java consumer and
Jay Kreps created KAFKA-2091:
Summary: Expose a Partitioner interface in the new producer
Key: KAFKA-2091
URL: https://issues.apache.org/jira/browse/KAFKA-2091
Project: Kafka
Issue Type:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/31806/#review78892
---
core/src/test/scala/integration/kafka/api/ConsumerTest.scala
[
https://issues.apache.org/jira/browse/KAFKA-1728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1728.
--
Resolution: Fixed
Closing since it seems like the patch was committed.
update 082 docs
[
https://issues.apache.org/jira/browse/KAFKA-1343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1343.
--
Resolution: Cannot Reproduce
Kafka consumer iterator thread stalls
[
https://issues.apache.org/jira/browse/KAFKA-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14395959#comment-14395959
]
Jay Kreps commented on KAFKA-1367:
--
[~nehanarkhede] Does this problem still exist?
[
https://issues.apache.org/jira/browse/KAFKA-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1501:
-
Resolution: Fixed
Status: Resolved (was: Patch Available)
Committed. [~ewencp] is my personal
[
https://issues.apache.org/jira/browse/KAFKA-1086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1086.
--
Resolution: Fixed
Assuming this is either fixed or not going to be.
Improve GetOffsetShell to find
[
https://issues.apache.org/jira/browse/KAFKA-1500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1500.
--
Resolution: Fixed
adding new consumer requests using the new protocol
[
https://issues.apache.org/jira/browse/KAFKA-264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-264.
-
Resolution: Won't Fix
I think this is no longer active.
Change the consumer side load balancing and
Hey guys,
I think the first step here would be to expose a partitioner interface for
the new producer that would make it easy to plug in these different
strategies. I filed a JIRA for this:
https://issues.apache.org/jira/browse/KAFKA-2091
-Jay
On Fri, Apr 3, 2015 at 9:36 AM, Harsha
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/31806/#review78891
---
core/src/test/scala/integration/kafka/api/ConsumerTest.scala
[
https://issues.apache.org/jira/browse/KAFKA-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14395955#comment-14395955
]
Jay Kreps commented on KAFKA-1729:
--
[~jjkoshy] is this still waiting on an update from
[
https://issues.apache.org/jira/browse/KAFKA-1303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14395960#comment-14395960
]
Jay Kreps commented on KAFKA-1303:
--
[~junrao] What is the status of this?
metadata
[
https://issues.apache.org/jira/browse/KAFKA-583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-583.
-
Resolution: Won't Fix
SimpleConsumerShell may receive less data inconsistently
[
https://issues.apache.org/jira/browse/KAFKA-777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-777.
-
Resolution: Won't Fix
Add system tests for important tools
[
https://issues.apache.org/jira/browse/KAFKA-552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-552.
-
Resolution: Won't Fix
No error messages logged for those failing-to-send messages from Producer
[
https://issues.apache.org/jira/browse/KAFKA-530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-530.
-
Resolution: Won't Fix
kafka.server.KafkaApis: kafka.common.OffsetOutOfRangeException
See https://builds.apache.org/job/KafkaPreCommit/54/changes
[
https://issues.apache.org/jira/browse/KAFKA-1293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14395991#comment-14395991
]
Jay Kreps commented on KAFKA-1293:
--
[~mwarhaftig] Did we get you wiki access?
Mirror
[
https://issues.apache.org/jira/browse/KAFKA-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps resolved KAFKA-1996.
--
Resolution: Fixed
Reviewer: Jay Kreps
Scaladoc error: unknown tag parameter
Hi,
I'm trying to rebase KAFKA-1809 after KAFKA-1501 was committed, and I'm
running into a chicken and egg problem.
In my design, SocketServer creates a map of port-SecurityProtocol.
This map is passed to Processor when it is initialized, and Processor uses
it to route requests to the correct
[
https://issues.apache.org/jira/browse/KAFKA-1904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14396003#comment-14396003
]
Gwen Shapira commented on KAFKA-1904:
-
Depends on whether we are planning to keep
[
https://issues.apache.org/jira/browse/KAFKA-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14396005#comment-14396005
]
Sriharsha Chintalapani commented on KAFKA-2082:
---
[~junrao] You are right
See https://builds.apache.org/job/KafkaPreCommit/55/changes
Changes:
[jay.kreps] KAFKA-2024 Log compaction can generate unindexable segments.
[jay.kreps] KAFKA-1996 Fix scaladoc error.
--
[...truncated 633 lines...]
kafka.consumer.ConsumerIteratorTest
[
https://issues.apache.org/jira/browse/KAFKA-1293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14396007#comment-14396007
]
Matt Warhaftig commented on KAFKA-1293:
---
[~jkreps] No, still don't have edit
61 matches
Mail list logo
