[jira] [Commented] (KAFKA-5018) LogCleaner tests to verify behaviour of message format v2

[ https://issues.apache.org/jira/browse/KAFKA-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980276#comment-15980276 ] Armin Braun commented on KAFKA-5018: Trying this one today :) > LogCleaner tests to v

[jira] [Assigned] (KAFKA-5018) LogCleaner tests to verify behaviour of message format v2

[ https://issues.apache.org/jira/browse/KAFKA-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Armin Braun reassigned KAFKA-5018: -- Assignee: Armin Braun > LogCleaner tests to verify behaviour of message format v2 > ---

Re: [DISCUSS] KIP 141 - ProducerRecordBuilder Interface

Good call. That’s when I heavily miss Scala Case classes and options. You get clarity on optional vs mandatory fields, one constructor, and immutability. If losing Immutability is an issue, then the with pattern is a no-go and then I’ll just add a missing constructor the way Ismael described it.

Re: [DISCUSS] KIP 141 - ProducerRecordBuilder Interface

If moving to a wither pattern instead of a builder. How will this enforce immutability? Eg current PR it is now changing to allow possible change values once set. Or are you proposing to change it to a mutable record? And move to a closable record similar to the closing of the headers on send.

[jira] [Commented] (KAFKA-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18

[ https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980250#comment-15980250 ] Matthias J. Sax commented on KAFKA-5070: I had KAFKA-5038 in mind (not 100% sure t

[jira] [Comment Edited] (KAFKA-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18

[ https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980250#comment-15980250 ] Matthias J. Sax edited comment on KAFKA-5070 at 4/23/17 4:10 AM: ---

[jira] [Resolved] (KAFKA-4087) DefaultParitioner Implementation Issue

[ https://issues.apache.org/jira/browse/KAFKA-4087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharat Viswanadham resolved KAFKA-4087. --- Resolution: Not A Bug > DefaultParitioner Implementation Issue > -

[jira] [Commented] (KAFKA-4087) DefaultParitioner Implementation Issue

[ https://issues.apache.org/jira/browse/KAFKA-4087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980200#comment-15980200 ] Bharat Viswanadham commented on KAFKA-4087: --- This is according to design, when k

Re: [DISCUSS] KIP 141 - ProducerRecordBuilder Interface

On Sat, Apr 22, 2017 at 6:16 PM, Matthias J. Sax wrote: > I think Ismael's suggestion is a valid alternative. > > However, `timestamp` is an optional field and thus we should have at > least two constructors for this: > > - ProducerRecord(String topic, K key, V value) - ProducerRecord(String t

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

See

[jira] [Created] (KAFKA-5114) Clarify meaning of logs in Introduction: Topics and Logs

Michael Ernest created KAFKA-5114: - Summary: Clarify meaning of logs in Introduction: Topics and Logs Key: KAFKA-5114 URL: https://issues.apache.org/jira/browse/KAFKA-5114 Project: Kafka Issu

Re: [VOTE] 0.10.2.1 RC3

It's listed below: * Maven artifacts to be voted upon: https://repository.apache.org/content/groups/staging/ On 22/04/17 19:23, Shimi Kiviti wrote: Is there a maven repo with these jars so I can test it against our kafka streams services? On Sat, Apr 22, 2017 at 9:05 PM, Eno Thereska wrote

Re: [VOTE] 0.10.2.1 RC3

Is there a maven repo with these jars so I can test it against our kafka streams services? On Sat, Apr 22, 2017 at 9:05 PM, Eno Thereska wrote: > +1 tested the usual streams tests as before. > > Thanks > Eno > > On 21 Apr 2017, at 17:56, Gwen Shapira wrote: > > > > Hello Kafka users, developers

[GitHub] kafka pull request #2759: MINOR: Move `Os` class to utils package and rename...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2759 --- 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] [Commented] (KAFKA-4692) Transient test failure in org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980117#comment-15980117 ] ASF GitHub Bot commented on KAFKA-4692: --- Github user original-brownbear closed the p

[GitHub] kafka pull request #2775: MINOR: Reduce Fork Count in ITs

Github user original-brownbear closed the pull request at: https://github.com/apache/kafka/pull/2775 --- 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 fea

[jira] [Commented] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast

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

[GitHub] kafka pull request #2897: KAFKA-4564: follow up hotfix for system test

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2897 KAFKA-4564: follow up hotfix for system test You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka KAFKA-4564-follow-up Alternatively you c

Re: [VOTE] 0.10.2.1 RC3

+1 tested the usual streams tests as before. Thanks Eno > On 21 Apr 2017, at 17:56, Gwen Shapira wrote: > > Hello Kafka users, developers, friends, romans, countrypersons, > > This is the fourth (!) candidate for release of Apache Kafka 0.10.2.1. > > It is a bug fix release, so we have lots of

[jira] [Commented] (KAFKA-4849) Bug in KafkaStreams documentation

[ https://issues.apache.org/jira/browse/KAFKA-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980034#comment-15980034 ] Matthias J. Sax commented on KAFKA-4849: This PR seems to relate to this JIRA, too

Re: [DISCUSS] KIP 141 - ProducerRecordBuilder Interface

I think Ismael's suggestion is a valid alternative. However, `timestamp` is an optional field and thus we should have at least two constructors for this: - ProducerRecord(String topic, K key, V value) - ProducerRecord(String topic, K key, V value, Long timestamp) > If anything, I think the wi

[jira] [Commented] (KAFKA-4912) Add check for topic name length

[ https://issues.apache.org/jira/browse/KAFKA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980030#comment-15980030 ] Matthias J. Sax commented on KAFKA-4912: Thanks for the update! > Add check for t

[jira] [Commented] (KAFKA-5100) ProducerPerformanceService failing due to parsing error

[ https://issues.apache.org/jira/browse/KAFKA-5100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980028#comment-15980028 ] Jun Rao commented on KAFKA-5100: It seems that tests/kafkatest/sanity_checks/test_performa

[GitHub] kafka pull request #2896: Minor: Make sure ProducerPerformance can bind with...

GitHub user junrao opened a pull request: https://github.com/apache/kafka/pull/2896 Minor: Make sure ProducerPerformance can bind with older client jar You can merge this pull request into a Git repository by running: $ git pull https://github.com/junrao/kafka minor Alternati

Re: [VOTE] KIP-114: KTable state stores and improved semantics

+1 Very well thought out. -Jay On Fri, Apr 21, 2017 at 10:39 AM Eno Thereska wrote: > Hi there, > > Unless there are more issues on the discuss thread, I'd like to start the > vote on KIP-114. > https://cwiki.apache.org/confluence/display/KAFKA/KIP-114%3A+KTable+state+stores+and+improved+semant

[jira] [Commented] (KAFKA-5098) KafkaProducer.send() blocks and generates TimeoutException if topic name has illegal char

[ https://issues.apache.org/jira/browse/KAFKA-5098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979910#comment-15979910 ] Umesh Chaudhary commented on KAFKA-5098: I will reproduce and work on this. > Ka

Re: [VOTE] KIP-114: KTable state stores and improved semantics

+1 On Fri, 21 Apr 2017 at 19:21 Sriram Subramanian wrote: > +1 > > On Fri, Apr 21, 2017 at 11:06 AM, Guozhang Wang > wrote: > > > +1 > > > > On Fri, Apr 21, 2017 at 10:52 AM, Bill Bejeck wrote: > > > > > +1 > > > On Fri, Apr 21, 2017 at 1:48 PM Matthias J. Sax > > > > wrote: > > > > > > > +1

[jira] [Created] (KAFKA-5113) Tidy up usage of Errors.INVALID_FETCH_SIZE and InvalidFetchSizeException

Damian Guy created KAFKA-5113: - Summary: Tidy up usage of Errors.INVALID_FETCH_SIZE and InvalidFetchSizeException Key: KAFKA-5113 URL: https://issues.apache.org/jira/browse/KAFKA-5113 Project: Kafka