Re: [DISCUSS] KIP-82 - Add Record Headers

Matthias, Thanks for your input. I'm +1 on control messages as they seem to be the simplest way to implement watermarks ( https://www.oreilly.com/ideas/the-world-beyond-batch-streaming-102), a feature that would add a lot of value to Kafka Streams IMHO. Your argument that the control-message ind

[jira] [Commented] (KAFKA-4526) Transient failure in ThrottlingTest.test_throttled_reassignment

[ https://issues.apache.org/jira/browse/KAFKA-4526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15758205#comment-15758205 ] Apurva Mehta commented on KAFKA-4526: - Thanks [~theduderog], I am looking at this and

[jira] [Commented] (KAFKA-3808) Transient failure in ReplicaVerificationToolTest

[ https://issues.apache.org/jira/browse/KAFKA-3808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15758169#comment-15758169 ] Roger Hoover commented on KAFKA-3808: - Happened again: {code} ---

[jira] [Resolved] (KAFKA-4554) ReplicaVerificationToolTest.test_replica_lags system test failure

[ https://issues.apache.org/jira/browse/KAFKA-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roger Hoover resolved KAFKA-4554. - Resolution: Duplicate Duplicate of https://issues.apache.org/jira/browse/KAFKA-3808 > ReplicaVer

[jira] [Created] (KAFKA-4554) ReplicaVerificationToolTest.test_replica_lags system test failure

Roger Hoover created KAFKA-4554: --- Summary: ReplicaVerificationToolTest.test_replica_lags system test failure Key: KAFKA-4554 URL: https://issues.apache.org/jira/browse/KAFKA-4554 Project: Kafka

[jira] [Commented] (KAFKA-4166) TestMirrorMakerService.test_bounce transient system test failure

[ https://issues.apache.org/jira/browse/KAFKA-4166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15758158#comment-15758158 ] Roger Hoover commented on KAFKA-4166: - Failed again: http://confluent-systest.s3-webs

[jira] [Commented] (KAFKA-4526) Transient failure in ThrottlingTest.test_throttled_reassignment

[ https://issues.apache.org/jira/browse/KAFKA-4526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15758155#comment-15758155 ] Roger Hoover commented on KAFKA-4526: - Failed again {code} --

[jira] [Updated] (KAFKA-4553) Connect's round robin assignment produces undesirable distribution of connectors/tasks

[ https://issues.apache.org/jira/browse/KAFKA-4553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4553: - Status: Patch Available (was: Open) > Connect's round robin assignment produces u

[jira] [Commented] (KAFKA-4553) Connect's round robin assignment produces undesirable distribution of connectors/tasks

[ https://issues.apache.org/jira/browse/KAFKA-4553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15757854#comment-15757854 ] ASF GitHub Bot commented on KAFKA-4553: --- GitHub user ewencp opened a pull request:

[GitHub] kafka pull request #2272: KAFKA-4553: Improve round robin assignment in Conn...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/2272 KAFKA-4553: Improve round robin assignment in Connect to avoid uneven distributions of connectors and tasks You can merge this pull request into a Git repository by running: $ git pull https:/

[jira] [Created] (KAFKA-4553) Connect's round robin assignment produces undesirable distribution of connectors/tasks

Ewen Cheslack-Postava created KAFKA-4553: Summary: Connect's round robin assignment produces undesirable distribution of connectors/tasks Key: KAFKA-4553 URL: https://issues.apache.org/jira/browse/KAFKA-45

[jira] [Commented] (KAFKA-4187) Adding a flag to prefix topics with mirror maker

[ https://issues.apache.org/jira/browse/KAFKA-4187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15757261#comment-15757261 ] Vincent Rischmann commented on KAFKA-4187: -- Yes you can close it, I ended up usin

[GitHub] kafka pull request #2271: MINOR: Improvements to Record related classes (WIP...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/2271 MINOR: Improvements to Record related classes (WIP) Jason recently cleaned things up significantly by consolidating the Message/Record classes into the common Java code in the clients module. While r

Build failed in Jenkins: kafka-trunk-jdk8 #1111

See Changes: [ismael] KAFKA-3600; Use ApiVersions to check if broker supports required api -- [...truncated 15050 lines...] org.apache.kafka.common.record.MemoryRecordsBuilderTest > buildUsingL

Jenkins build is back to normal : kafka-trunk-jdk7 #1763

See

[jira] [Updated] (KAFKA-3600) Enhance java clients to use ApiVersion Req/Resp to check if the broker they are talking to supports required api versions

[ https://issues.apache.org/jira/browse/KAFKA-3600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3600: --- Resolution: Fixed Status: Resolved (was: Patch Available) > Enhance java clients to use ApiVe

[jira] [Commented] (KAFKA-3600) Enhance java clients to use ApiVersion Req/Resp to check if the broker they are talking to supports required api versions

[ https://issues.apache.org/jira/browse/KAFKA-3600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15756930#comment-15756930 ] ASF GitHub Bot commented on KAFKA-3600: --- Github user asfgit closed the pull request

[GitHub] kafka pull request #1251: KAFKA-3600: Enhance java clients to use ApiVersion...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1251 --- 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 enab

[jira] [Updated] (KAFKA-4526) Transient failure in ThrottlingTest.test_throttled_reassignment

[ https://issues.apache.org/jira/browse/KAFKA-4526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4526: --- Assignee: Apurva Mehta (was: Jason Gustafson) > Transient failure in ThrottlingTest.test_throttled_re

[jira] [Updated] (KAFKA-4166) TestMirrorMakerService.test_bounce transient system test failure

[ https://issues.apache.org/jira/browse/KAFKA-4166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4166: --- Assignee: Jason Gustafson > TestMirrorMakerService.test_bounce transient system test failure > ---

Re: [VOTE] KIP-100 - Relax Type constraints in Kafka Streams API

Thanks Xavier. +1 (binding) Ismael On Fri, Dec 16, 2016 at 8:15 PM, Xavier Léauté wrote: > Ismael made a good point so I updated KIP-100 and expanded its scope to > include covariant result types for functions applied to streams. > I will update the discussion thread accordingly. > > On Tue, De