Ewen Cheslack-Postava created KAFKA-2483:
Summary: Add support for batch/scheduled Copycat connectors
Key: KAFKA-2483
URL: https://issues.apache.org/jira/browse/KAFKA-2483
Project: Kafka
Ewen Cheslack-Postava created KAFKA-2484:
Summary: Add schema projection utilities
Key: KAFKA-2484
URL: https://issues.apache.org/jira/browse/KAFKA-2484
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-2480:
-
Summary: Handle non-CopycatExceptions from SinkTasks (was: Handle
Ewen Cheslack-Postava created KAFKA-2482:
Summary: Allow copycat sink tasks to pause/resume consumption of
specific topic partitions
Key: KAFKA-2482
URL: https://issues.apache.org/jira/browse/KAFKA-2482
Ewen Cheslack-Postava created KAFKA-2480:
Summary: Handle non-CopycatExceptions from
Key: KAFKA-2480
URL: https://issues.apache.org/jira/browse/KAFKA-2480
Project: Kafka
Issue Type:
Ewen Cheslack-Postava created KAFKA-2479:
Summary: Add CopycatExceptions to indicate transient and permanent
errors in a connector/task
Key: KAFKA-2479
URL:
Ewen Cheslack-Postava created KAFKA-2481:
Summary: Allow copycat sinks to request periodic invocation of put
even if no new data is available
Key: KAFKA-2481
URL:
Hi,
We have built the latest kafka from https://github.com/apache/kafka based
on this commit id 436b7ddc386eb688ba0f12836710f5e4bcaa06c8 .
We ran the performance test on a 3 node kafka cluster. There is a huge
throughput degradation using the new-consumer compared to the regular
consumer. Below
Github user asfgit closed the pull request at:
https://github.com/apache/kafka/pull/163
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
See https://builds.apache.org/job/Kafka-trunk/604/changes
[
https://issues.apache.org/jira/browse/KAFKA-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira updated KAFKA-2367:
Resolution: Fixed
Status: Resolved (was: Patch Available)
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717315#comment-14717315
]
ASF GitHub Bot commented on KAFKA-2367:
---
Github user asfgit closed the pull request
Hey Joel,
I really don't think we should do both. There are pros and cons but we
should make a decision and work on operationalizing one approach. Much of
really making something like this work is getting all the bugs out, getting
monitoring in place, getting rigorous system tests in place.
[
https://issues.apache.org/jira/browse/KAFKA-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira updated KAFKA-2377:
Resolution: Fixed
Status: Resolved (was: Patch Available)
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-2377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717506#comment-14717506
]
ASF GitHub Bot commented on KAFKA-2377:
---
Github user asfgit closed the pull request
I actually feel these set of tests (whatever they may be) are somewhat
irrelevant here. My main concern with the current client-side proposal
(i.e., without Becket's follow-up suggestions) is that it makes a
significant compromise to the original charter of the new consumer -
i.e.,
[
https://issues.apache.org/jira/browse/KAFKA-2475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717551#comment-14717551
]
ASF GitHub Bot commented on KAFKA-2475:
---
GitHub user ewencp opened a pull request:
[
https://issues.apache.org/jira/browse/KAFKA-2475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-2475:
-
Reviewer: Gwen Shapira
Status: Patch Available (was: Open)
Reduce copycat
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/172
KAFKA-2475: Make Copycat only have a Converter class instead of Serializer,
Deserializer, and Converter.
The Converter class now translates directly between byte[] and Copycat's
data
API instead
I don't think the commands are really equivalent despite just adding the
--new-consumer flag. ConsumerPerformance uses a single thread when using
the new consumer (it literally just allocates the consumer, loops until
it's consumed enough, then exits), whereas the old consumer uses a bunch of
I think this is likely a regression. The two clients had more or less
equivalent performance when we checked in the code (see my post on this
earlier in the year). Looks like maybe we broke something up in the interim?
On my laptop the new consumer perf seems to have dropped from about
~200MB/sec
[
https://issues.apache.org/jira/browse/KAFKA-1912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14718092#comment-14718092
]
Ashish K Singh commented on KAFKA-1912:
---
[~jkreps], [~guozhang] are we still
[
https://issues.apache.org/jira/browse/KAFKA-2485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717963#comment-14717963
]
Dong Lin commented on KAFKA-2485:
-
[~ewencp] I didn't add this to the Java producer
436b7ddc386eb688ba0f12836710f5e4bcaa06c8 is pretty recent and there could
be some current consumer improvement patches that introduces some
regression. I would suggest doing a binary search in the log from
3f8480ccfb011eb43da774737597c597f703e11b
(maybe even earlier?) to do a quick check.
[
https://issues.apache.org/jira/browse/KAFKA-2471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14718087#comment-14718087
]
Ashish K Singh commented on KAFKA-2471:
---
Could you attach server.log
Replicas
[
https://issues.apache.org/jira/browse/KAFKA-2485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717952#comment-14717952
]
Ewen Cheslack-Postava commented on KAFKA-2485:
--
[~lindong] This looks good
[
https://issues.apache.org/jira/browse/KAFKA-2485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-2485:
-
Summary: Allow producer performance to take properties from a file via
Github user asfgit closed the pull request at:
https://github.com/apache/kafka/pull/167
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/KAFKA-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-2461:
--
Status: Patch Available (was: Open)
request logger no longer logs extra information in debug
[
https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-2468.
--
Resolution: Fixed
Fix Version/s: 0.8.3
Issue resolved by pull request 167
[
https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14718017#comment-14718017
]
ASF GitHub Bot commented on KAFKA-2468:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/KAFKA-2478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716428#comment-14716428
]
Ismael Juma commented on KAFKA-2478:
[~devstr], yes, you can submit a PR. Instructions
GitHub user omkreddy opened a pull request:
https://github.com/apache/kafka/pull/171
KAFKA-2425; Copy latest docs to kafka repo docs/ directory
This PR copies the latest kafka docs to kafka repo docs directory. Here I
have copied 0.8.3/ directory contents from svn website repo to
[
https://issues.apache.org/jira/browse/KAFKA-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716436#comment-14716436
]
ASF GitHub Bot commented on KAFKA-2425:
---
GitHub user omkreddy opened a pull request:
[
https://issues.apache.org/jira/browse/KAFKA-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716460#comment-14716460
]
ASF GitHub Bot commented on KAFKA-2425:
---
GitHub user omkreddy reopened a pull
GitHub user omkreddy reopened a pull request:
https://github.com/apache/kafka/pull/171
KAFKA-2425; Copy latest docs to kafka repo docs/ directory
This PR copies the latest kafka docs to kafka repo docs directory. Here I
have copied 0.8.3/ directory contents from svn website repo to
Github user omkreddy closed the pull request at:
https://github.com/apache/kafka/pull/171
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/KAFKA-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716459#comment-14716459
]
ASF GitHub Bot commented on KAFKA-2425:
---
Github user omkreddy closed the pull
[
https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716229#comment-14716229
]
David Jacot commented on KAFKA-2072:
[~ijuma] Do you also need rest of this one for
[
https://issues.apache.org/jira/browse/KAFKA-2074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2074 started by Ismael Juma.
--
Add UpdateMetadata request/response to o.a.k.common.requests and replace its
use
[
https://issues.apache.org/jira/browse/KAFKA-2074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma reassigned KAFKA-2074:
--
Assignee: Ismael Juma (was: Sriharsha Chintalapani)
Add UpdateMetadata request/response to
[
https://issues.apache.org/jira/browse/KAFKA-2074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716259#comment-14716259
]
Ismael Juma commented on KAFKA-2074:
Doing this as part of KAFKA-2411, so assigning it
[
https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716261#comment-14716261
]
Ismael Juma commented on KAFKA-2072:
Migration of `KafkaAPIs` is not needed for
[
https://issues.apache.org/jira/browse/KAFKA-2478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716378#comment-14716378
]
Dmitry Stratiychuk commented on KAFKA-2478:
---
Can certainly do for the javadoc
[
https://issues.apache.org/jira/browse/KAFKA-2065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2065 started by Ismael Juma.
--
Add ControlledShutdown to org.apache.kafka.common.requests and replace
current
[
https://issues.apache.org/jira/browse/KAFKA-2067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2067 started by Ismael Juma.
--
Add LeaderAndISR request/response to org.apache.kafka.common.requests and
replace
[
https://issues.apache.org/jira/browse/KAFKA-2485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2485 started by Dong Lin.
---
Allow producer performance to take properties from a file via
--consumer.config command
[
https://issues.apache.org/jira/browse/KAFKA-2485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2485:
Status: Patch Available (was: In Progress)
Allow producer performance to take properties from a file via
[
https://issues.apache.org/jira/browse/KAFKA-2485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717815#comment-14717815
]
ASF GitHub Bot commented on KAFKA-2485:
---
GitHub user lindong28 opened a pull
GitHub user granders opened a pull request:
https://github.com/apache/kafka/pull/173
MINOR: kafkatest add manifest
This patch makes it possible to publish kafkatest (system test package) to
pypi and use it as a library in other projects by:
- including necessary static
GitHub user lindong28 opened a pull request:
https://github.com/apache/kafka/pull/174
KAFKA-2485; Allow producer performance to take properties from a fileâ¦
⦠via --consumer.config command line parameter
You can merge this pull request into a Git repository by running:
$
51 matches
Mail list logo
