[jira] [Commented] (KAFKA-4578) Upgrade notes for 0.10.2.0

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

[jira] [Commented] (KAFKA-4701) Allow kafka brokers to dynamically reload truststore without restarting.

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

[GitHub] kafka pull request #2446: KAFKA-4701: Add dynamic truststore manager.

GitHub user allenxiang opened a pull request: https://github.com/apache/kafka/pull/2446 KAFKA-4701: Add dynamic truststore manager. Allow kafka brokers to dynamically reload truststore without restarting. You can merge this pull request into a Git repository by running: $ git

[jira] [Commented] (KAFKA-4578) Upgrade notes for 0.10.2.0

[ https://issues.apache.org/jira/browse/KAFKA-4578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839783#comment-15839783 ] Ismael Juma commented on KAFKA-4578: PR: https://github.com/apache/kafka/pull/2445 > Upgrade notes

[jira] [Updated] (KAFKA-4578) Upgrade notes for 0.10.2.0

[ https://issues.apache.org/jira/browse/KAFKA-4578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4578: --- Status: Patch Available (was: Open) > Upgrade notes for 0.10.2.0 > -- > >

[jira] [Created] (KAFKA-4701) Allow kafka brokers to dynamically reload truststore without restarting.

Allen Xiang created KAFKA-4701: -- Summary: Allow kafka brokers to dynamically reload truststore without restarting. Key: KAFKA-4701 URL: https://issues.apache.org/jira/browse/KAFKA-4701 Project: Kafka

[jira] [Commented] (KAFKA-4645) Improve test coverage of ProcessorTopology

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

[jira] [Updated] (KAFKA-4645) Improve test coverage of ProcessorTopology

[ https://issues.apache.org/jira/browse/KAFKA-4645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4645: -- Status: Patch Available (was: Open) > Improve test coverage of ProcessorTopology >

[GitHub] kafka pull request #2444: KAFKA-4645: Improve test coverage of ProcessorTopo...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/2444 KAFKA-4645: Improve test coverage of ProcessorTopology the toString method prints the topology, but had no tests making sure it works and/or doesn't cause exceptions You can merge this pull request

[jira] [Assigned] (KAFKA-4646) Improve test coverage AbstractProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4646: - Assignee: Damian Guy > Improve test coverage AbstractProcessorContext >

[GitHub] kafka pull request #2443: MINOR: Close create topics policy during shutdown ...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/2443 MINOR: Close create topics policy during shutdown and more tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka

Build failed in Jenkins: kafka-0.10.2-jdk7 #39

See Changes: [ismael] KAFKA-4630; Implement RecordTooLargeException when communicating with -- [...truncated 8304 lines...] kafka.network.SocketServerTest > tooBigRequestIsRejected STARTED

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

See Changes: [ismael] KAFKA-4630; Implement RecordTooLargeException when communicating with -- [...truncated 4063 lines...] kafka.integration.SaslPlaintextTopicMetadataTest >

[jira] [Assigned] (KAFKA-4645) Improve test coverage of ProcessorTopology

[ https://issues.apache.org/jira/browse/KAFKA-4645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4645: - Assignee: Damian Guy > Improve test coverage of ProcessorTopology >

[jira] [Updated] (KAFKA-4642) Improve test coverage of ProcessorStateManager

[ https://issues.apache.org/jira/browse/KAFKA-4642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4642: -- Status: Patch Available (was: In Progress) > Improve test coverage of ProcessorStateManager >

[jira] [Commented] (KAFKA-4642) Improve test coverage of ProcessorStateManager

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

[GitHub] kafka pull request #2442: KAFKA-4642: Improve test coverage of ProcessorStat...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/2442 KAFKA-4642: Improve test coverage of ProcessorStateManager Most of the exception paths weren't covered. Now they are. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Work started] (KAFKA-4642) Improve test coverage of ProcessorStateManager

[ https://issues.apache.org/jira/browse/KAFKA-4642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4642 started by Damian Guy. - > Improve test coverage of ProcessorStateManager >

[jira] [Comment Edited] (KAFKA-4557) ConcurrentModificationException in KafkaProducer event loop

[ https://issues.apache.org/jira/browse/KAFKA-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839637#comment-15839637 ] Sergey Alaev edited comment on KAFKA-4557 at 1/26/17 12:31 PM: --- [~rsivaram]

[jira] [Commented] (KAFKA-4557) ConcurrentModificationException in KafkaProducer event loop

[ https://issues.apache.org/jira/browse/KAFKA-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839637#comment-15839637 ] Sergey Alaev commented on KAFKA-4557: - [~rsivaram] Yep, that's seems to be the case. Actual code is

[jira] [Updated] (KAFKA-4700) StreamsKafkaClient drops security configs

[ https://issues.apache.org/jira/browse/KAFKA-4700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4700: --- Description: `StreamsKafkaClient` takes a `StreamsConfig` and calls `values` on it to create a

[jira] [Updated] (KAFKA-4700) StreamsKafkaClient drops security configs

[ https://issues.apache.org/jira/browse/KAFKA-4700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4700: --- Status: Patch Available (was: Open) > StreamsKafkaClient drops security configs >

Re: [DISCUSS] KIP-115: Enforce offsets.topic.replication.factor

If I understood well, this KIP is trying to solve for the problem of offsets.topic.replication.factor not being enforced, particularly in context of "when you have clients or tooling running as the cluster is getting setup". Assuming that this problem was observed in production, so in non-testing

Build failed in Jenkins: kafka-trunk-jdk7 #1881

See Changes: [ismael] KAFKA-4630; Implement RecordTooLargeException when communicating with -- [...truncated 4066 lines...] kafka.log.LogTest > testReadWithTooSmallMaxLength STARTED

[jira] [Commented] (KAFKA-4557) ConcurrentModificationException in KafkaProducer event loop

[ https://issues.apache.org/jira/browse/KAFKA-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839627#comment-15839627 ] Ismael Juma commented on KAFKA-4557: Yes, that makes sense. Thanks for figuring it out. :) >

[jira] [Commented] (KAFKA-4700) StreamsKafkaClient drops security configs

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

[GitHub] kafka pull request #2441: KAFKA-4700: Don't drop security configs in `Stream...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/2441 KAFKA-4700: Don't drop security configs in `StreamsKafkaClient` You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka

[jira] [Commented] (KAFKA-4557) ConcurrentModificationException in KafkaProducer event loop

[ https://issues.apache.org/jira/browse/KAFKA-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839608#comment-15839608 ] Rajini Sivaram commented on KAFKA-4557: --- [~ijuma] Yes, if a message is sent to the same partition

[jira] [Assigned] (KAFKA-4642) Improve test coverage of ProcessorStateManager

[ https://issues.apache.org/jira/browse/KAFKA-4642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4642: - Assignee: Damian Guy > Improve test coverage of ProcessorStateManager >

[jira] [Created] (KAFKA-4700) StreamsKafkaClient drops security configs

Ismael Juma created KAFKA-4700: -- Summary: StreamsKafkaClient drops security configs Key: KAFKA-4700 URL: https://issues.apache.org/jira/browse/KAFKA-4700 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-4557) ConcurrentModificationException in KafkaProducer event loop

[ https://issues.apache.org/jira/browse/KAFKA-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839589#comment-15839589 ] Ismael Juma commented on KAFKA-4557: [~rsivaram], oh so you mean the issue is that we are modifying

[jira] [Commented] (KAFKA-4557) ConcurrentModificationException in KafkaProducer event loop

[ https://issues.apache.org/jira/browse/KAFKA-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839587#comment-15839587 ] Rajini Sivaram commented on KAFKA-4557: --- [~salaev] Does the producer application send messages from

[jira] [Commented] (KAFKA-4630) Implement RecordTooLargeException when communicating with pre-KIP-74 brokers

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

[jira] [Updated] (KAFKA-4630) Implement RecordTooLargeException when communicating with pre-KIP-74 brokers

[ https://issues.apache.org/jira/browse/KAFKA-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4630: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[GitHub] kafka pull request #2390: KAFKA-4630: Implement RecordTooLargeException when...

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

[jira] [Assigned] (KAFKA-4557) ConcurrentModificationException in KafkaProducer event loop

[ https://issues.apache.org/jira/browse/KAFKA-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-4557: - Assignee: Rajini Sivaram > ConcurrentModificationException in KafkaProducer event loop >

Re: [VOTE] KIP-115: Enforce offsets.topic.replication.factor

+1 On Thu, Jan 26, 2017 at 10:01 AM, Mickael Maison wrote: > +1 Thanks for the KIP ! > > On Thu, Jan 26, 2017 at 8:39 AM, Ben Stopford wrote: > > +1 > > Ben Stopford > > Confluent, http://www.confluent.io > > > > > > > >>

Re: [VOTE] KIP-115: Enforce offsets.topic.replication.factor

+1 Thanks for the KIP ! On Thu, Jan 26, 2017 at 8:39 AM, Ben Stopford wrote: > +1 > Ben Stopford > Confluent, http://www.confluent.io > > > >> On 26 Jan 2017, at 07:45, James Cheng wrote: >> >> +1 >> >>> On Jan 25, 2017, at

[jira] [Commented] (KAFKA-4699) Transient Failure PlaintextConsumerTest.testInterceptros

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

[GitHub] kafka pull request #2440: KAFKA-4699: Invoke producer callbacks before compl...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/2440 KAFKA-4699: Invoke producer callbacks before completing the future This behaviour was changed in 8b3c6c0, but it caused interceptor test failures (which rely on callbacks) and since we’re so

[jira] [Commented] (KAFKA-2700) delete topic should remove the corresponding ACL and configs

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

[GitHub] kafka pull request #2439: KAFKA-2700: Delete topic should remove the corresp...

GitHub user omkreddy opened a pull request: https://github.com/apache/kafka/pull/2439 KAFKA-2700: Delete topic should remove the corresponding ACLs You can merge this pull request into a Git repository by running: $ git pull https://github.com/omkreddy/kafka

[jira] [Work started] (KAFKA-4699) Transient Failure PlaintextConsumerTest.testInterceptros

[ https://issues.apache.org/jira/browse/KAFKA-4699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4699 started by Ismael Juma. -- > Transient Failure PlaintextConsumerTest.testInterceptros >

[GitHub] kafka pull request #2351: MINOR: add Eclipse generated files to toplevel .gi...

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

Re: [VOTE] KIP-115: Enforce offsets.topic.replication.factor

+1 Ben Stopford Confluent, http://www.confluent.io > On 26 Jan 2017, at 07:45, James Cheng wrote: > > +1 > >> On Jan 25, 2017, at 9:48 PM, Ewen Cheslack-Postava wrote: >> >> +1 >> >> On Wed, Jan 25, 2017 at 9:23 PM, Joel

[GitHub] kafka pull request #2438: MINOR: update KTable JavaDoc

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2438 MINOR: update KTable JavaDoc You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka ktableJavaDocs Alternatively you can review and apply

[GitHub] kafka pull request #2437: MINOR: Streams API JavaDoc improvements

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2437 MINOR: Streams API JavaDoc improvements You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka javaDocImprovements7 Alternatively you can

[jira] [Updated] (KAFKA-4450) Add missing 0.10.1.x upgrade tests and ensure ongoing compatibility checks

[ https://issues.apache.org/jira/browse/KAFKA-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4450: - Priority: Blocker (was: Critical) > Add missing 0.10.1.x upgrade tests and

<    1   2