[jira] [Commented] (KAFKA-3633) Kafka Consumer API breaking backward compatibility

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

[GitHub] kafka pull request: KAFKA-3633: Kafka Consumer API breaking backwa...

GitHub user hmcl opened a pull request: https://github.com/apache/kafka/pull/1281 KAFKA-3633: Kafka Consumer API breaking backward compatibility - Overload methods seekToBeginning(..), seekToEnd(..), pause(..), resume(..) with varargs parameter for backwards compatibility You can m

[jira] [Commented] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15261630#comment-15261630 ] Manikumar Reddy commented on KAFKA-3587: [~ecomar] your alternative approach looks

[GitHub] kafka pull request: MINOR: Remove some warning

GitHub user Ishiihara opened a pull request: https://github.com/apache/kafka/pull/1280 MINOR: Remove some warning @ijuma @junrao Can you take a look? You can merge this pull request into a Git repository by running: $ git pull https://github.com/Ishiihara/kafka minor-warning-fi

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

See Changes: [ismael] KAFKA-3621; Add tests for ApiVersionRequest/Response -- [...truncated 2411 lines...] kafka.server.KafkaConfigTest > testLogRetentionTimeMinutesProvided PASSED kafka.server

[Contributor List] - Request to be Added

Hi, I would like to ask to please be added to the Apache Kafka Contributor List. I have a PR that is ready to submit for review, and would like to assign to me the associated JIRA. GitHub: hmcl Apache JIRA Id: hmclouro Thanks, Hugo

[jira] [Commented] (KAFKA-3294) Kafka REST API

[ https://issues.apache.org/jira/browse/KAFKA-3294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15261562#comment-15261562 ] Parth Brahmbhatt commented on KAFKA-3294: - Here is a version we are working on ht

Re: [VOTE] KIP-56 Allow cross origin HTTP requests on all HTTP methods

+1 On Wed, Apr 27, 2016 at 1:54 PM, Grant Henke wrote: > +1 (non-binding) > > On Wed, Apr 27, 2016 at 3:35 PM, Harsha wrote: > > > +1 > > -Harsha > > > > On Wed, Apr 27, 2016, at 01:29 PM, Guozhang Wang wrote: > > > +1 > > > > > > On Wed, Apr 27, 2016 at 1:21 PM, Ewen Cheslack-Postava > > > >

Re: [DISCUSS] KIP-56 Allow cross origin HTTP requests on all HTTP methods

Thanks for the KIP, Liquan. One minor comment: it would be good to specify that if there are multiple methods, they should be comma-separated (assuming this is correct). Ismael On Mon, Apr 18, 2016 at 2:19 PM, Liquan Pei wrote: > Hi > > I would like to start a quick discussion on KIP-56 > > htt

[jira] [Updated] (KAFKA-3633) Kafka Consumer API breaking backward compatibility

[ https://issues.apache.org/jira/browse/KAFKA-3633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-3633: -- Fix Version/s: 0.10.0.0 > Kafka Consumer API breaking backward compatibility > -

[jira] [Created] (KAFKA-3633) Kafka Consumer API breaking backward compatibility

Sriharsha Chintalapani created KAFKA-3633: - Summary: Kafka Consumer API breaking backward compatibility Key: KAFKA-3633 URL: https://issues.apache.org/jira/browse/KAFKA-3633 Project: Kafka

Re: KAFKA-1981 Make log compaction point configurable

Hi Eric, As Ashish said, we need your Confluence id before we can grant you the permission. Thanks for doing this by the way. Ismael On Wed, Apr 27, 2016 at 5:00 PM, Ashish Singh wrote: > Hey Eric, > > One of the project committers should be able to grant permissions to you to > create a KIP w

Re: No Heartbeat request on commit

Hey Vinay, Any chance you can run the same test against trunk? I'm guessing this might be caused by a bug in the 0.9 consumer which basically causes some requests to fail when a bunch of them are sent to the broker at the same time. -Jason On Wed, Apr 27, 2016 at 1:02 PM, vinay sharma wrote: >

[jira] [Commented] (KAFKA-3621) Add tests for ApiVersionRequest/Response

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

[GitHub] kafka pull request: KAFKA-3621: Add tests for ApiVersionRequest/Re...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1275 --- 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] [Resolved] (KAFKA-3621) Add tests for ApiVersionRequest/Response

[ https://issues.apache.org/jira/browse/KAFKA-3621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3621. Resolution: Fixed Issue resolved by pull request 1275 [https://github.com/apache/kafka/pull/1275] >

[jira] [Commented] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15261312#comment-15261312 ] Kiran Pillarisetty commented on KAFKA-3587: --- [~ecomar] That sounds like a good t

[jira] [Resolved] (KAFKA-3631) Recent addition of "nullable array" to MetadataRequest is breaking MirrorMaker system tests

[ https://issues.apache.org/jira/browse/KAFKA-3631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3631. Resolution: Fixed Fix Version/s: 0.10.0.0 Issue resolved by pull request 1279 [https://github

[jira] [Commented] (KAFKA-3631) Recent addition of "nullable array" to MetadataRequest is breaking MirrorMaker system tests

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

[GitHub] kafka pull request: KAFKA-3631: Fix Struct.toString for nullable a...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1279 --- 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] [Work started] (KAFKA-3566) Enable VerifiableProducer and ConsoleConsumer to run with interceptors

[ https://issues.apache.org/jira/browse/KAFKA-3566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3566 started by Anna Povzner. --- > Enable VerifiableProducer and ConsoleConsumer to run with interceptors >

Re: KAFKA-1981 Make log compaction point configurable

Hey Eric, One of the project committers should be able to grant permissions to you to create a KIP wiki, but the first question you will get is, what is your confluence id. On Wed, Apr 27, 2016 at 4:54 PM, Eric Wasserman wrote: > I was requested by Ismael Juma ( > https://issues.apache.org/jira

[GitHub] kafka pull request: KAFKA-3612: Added structure for integration te...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1260 --- 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-3612) Add initial set of integration tests

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

[jira] [Resolved] (KAFKA-3612) Add initial set of integration tests

[ https://issues.apache.org/jira/browse/KAFKA-3612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3612. -- Resolution: Fixed Issue resolved by pull request 1260 [https://github.com/apache/kafka/pull/1260

KAFKA-1981 Make log compaction point configurable

I was requested by Ismael Juma ( https://issues.apache.org/jira/secure/ViewProfile.jspa?name=ijuma) to create a KIP for this patch because it adds configurations. I don't have the permissions in Confluence to add a child to the KIP page as instructed. Instead I added a markdown document as an attac

[jira] [Commented] (KAFKA-3631) Recent addition of "nullable array" to MetadataRequest is breaking MirrorMaker system tests

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

[GitHub] kafka pull request: KAFKA-3631: Fix Struct.toString for nullable a...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/1279 KAFKA-3631: Fix Struct.toString for nullable arrayOf You can merge this pull request into a Git repository by running: $ git pull https://github.com/granthenke/kafka struct-fix Alternative

[jira] [Commented] (KAFKA-2729) Cached zkVersion not equal to that in zookeeper, broker not recovering.

[ https://issues.apache.org/jira/browse/KAFKA-2729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15261189#comment-15261189 ] Kane Kim commented on KAFKA-2729: - Same problem with the same symptoms occurred on kafka 0

[jira] [Commented] (KAFKA-1382) Update zkVersion on partition state update failures

[ https://issues.apache.org/jira/browse/KAFKA-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15261182#comment-15261182 ] Kane Kim commented on KAFKA-1382: - We've been hitting this bug too on kafka 0.8.2.1: [201

[jira] [Commented] (KAFKA-3613) Consolidate tumbling windows and hopping windows

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

[GitHub] kafka pull request: KAFKA-3613: Consolidate TumblingWindows and Ho...

Github user miguno closed the pull request at: https://github.com/apache/kafka/pull/1261 --- 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-3597) Enable query ConsoleConsumer and VerifiableProducer if they shutdown cleanly

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

[GitHub] kafka pull request: KAFKA-3597: Query ConsoleConsumer and Verifiab...

GitHub user apovzner opened a pull request: https://github.com/apache/kafka/pull/1278 KAFKA-3597: Query ConsoleConsumer and VerifiableProducer if they shutdown cleanly Even if a test calls stop() on console_consumer or verifiable_producer, it is still possible that producer/consume

[jira] [Created] (KAFKA-3632) ConsumerLag metrics persist after partition migration

Brian Lueck created KAFKA-3632: -- Summary: ConsumerLag metrics persist after partition migration Key: KAFKA-3632 URL: https://issues.apache.org/jira/browse/KAFKA-3632 Project: Kafka Issue Type: B

[jira] [Commented] (KAFKA-3631) Recent addition of "nullable array" to MetadataRequest is breaking MirrorMaker system tests

[ https://issues.apache.org/jira/browse/KAFKA-3631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15261069#comment-15261069 ] Gwen Shapira commented on KAFKA-3631: - More important, our network processor got that

[jira] [Updated] (KAFKA-3631) Recent addition of "nullable array" to MetadataRequest is breaking MirrorMaker system tests

[ https://issues.apache.org/jira/browse/KAFKA-3631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3631: Assignee: Grant Henke > Recent addition of "nullable array" to MetadataRequest is breaking > Mirror

[jira] [Created] (KAFKA-3631) Recent addition of "nullable array" to MetadataRequest is breaking MirrorMaker system tests

Gwen Shapira created KAFKA-3631: --- Summary: Recent addition of "nullable array" to MetadataRequest is breaking MirrorMaker system tests Key: KAFKA-3631 URL: https://issues.apache.org/jira/browse/KAFKA-3631

[jira] [Work started] (KAFKA-3567) Add --security-protocol option to console consumer and producer

[ https://issues.apache.org/jira/browse/KAFKA-3567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3567 started by Bharat Viswanadham. - > Add --security-protocol option to console consumer and producer > ---

[jira] [Work started] (KAFKA-3613) Consolidate tumbling windows and hopping windows

[ https://issues.apache.org/jira/browse/KAFKA-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3613 started by Michael Noll. --- > Consolidate tumbling windows and hopping windows > --

[jira] [Assigned] (KAFKA-3613) Consolidate tumbling windows and hopping windows

[ https://issues.apache.org/jira/browse/KAFKA-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll reassigned KAFKA-3613: --- Assignee: Michael Noll > Consolidate tumbling windows and hopping windows > -

[jira] [Commented] (KAFKA-3613) Consolidate tumbling windows and hopping windows

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

[GitHub] kafka pull request: KAFKA-3613: Consolidate TumblingWindows and Ho...

GitHub user miguno opened a pull request: https://github.com/apache/kafka/pull/1277 KAFKA-3613: Consolidate TumblingWindows and HoppingWindows into TimeWindows This PR includes the same code as https://github.com/apache/kafka/pull/1261 but is rebased on latest trunk. You can merge

[jira] [Updated] (KAFKA-3262) Make KafkaStreams debugging friendly

[ https://issues.apache.org/jira/browse/KAFKA-3262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3262: - Labels: user-experience (was: developer-experience) > Make KafkaStreams debugging friendly >

[jira] [Work started] (KAFKA-3597) Enable query ConsoleConsumer and VerifiableProducer if they shutdown cleanly

[ https://issues.apache.org/jira/browse/KAFKA-3597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3597 started by Anna Povzner. --- > Enable query ConsoleConsumer and VerifiableProducer if they shutdown cleanly > --

[jira] [Updated] (KAFKA-3598) Improve JavaDoc of public API

[ https://issues.apache.org/jira/browse/KAFKA-3598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3598: - Labels: docs (was: ) > Improve JavaDoc of public API > - > >

[jira] [Updated] (KAFKA-3535) Add metrics ability for streams serde components

[ https://issues.apache.org/jira/browse/KAFKA-3535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3535: - Labels: user-experience (was: ) > Add metrics ability for streams serde components >

[jira] [Updated] (KAFKA-3574) Add missing @returns tags for JavaDoc

[ https://issues.apache.org/jira/browse/KAFKA-3574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3574: - Labels: docs (was: ) > Add missing @returns tags for JavaDoc > --

[jira] [Resolved] (KAFKA-3555) Unexpected close of KStreams transformer

[ https://issues.apache.org/jira/browse/KAFKA-3555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3555. -- Resolution: Not A Bug This is related to KAFKA-3559. The observation itself is not a bug. > Une

[jira] [Updated] (KAFKA-3612) Add initial set of integration tests

[ https://issues.apache.org/jira/browse/KAFKA-3612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3612: - Labels: test (was: ) > Add initial set of integration tests > ---

[jira] [Updated] (KAFKA-3113) Kafka simple consumer inconsistent result

[ https://issues.apache.org/jira/browse/KAFKA-3113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3113: - Component/s: (was: streams) > Kafka simple consumer inconsistent result >

[jira] [Updated] (KAFKA-3625) Move kafka-streams test fixtures into a published package

[ https://issues.apache.org/jira/browse/KAFKA-3625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3625: - Fix Version/s: (was: 0.10.0.0) 0.10.1.0 > Move kafka-streams test fixtures

[jira] [Updated] (KAFKA-3625) Move kafka-streams test fixtures into a published package

[ https://issues.apache.org/jira/browse/KAFKA-3625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3625: - Labels: user-experience (was: ) > Move kafka-streams test fixtures into a published package > ---

Re: [VOTE] KIP-56 Allow cross origin HTTP requests on all HTTP methods

+1 (non-binding) On Wed, Apr 27, 2016 at 3:35 PM, Harsha wrote: > +1 > -Harsha > > On Wed, Apr 27, 2016, at 01:29 PM, Guozhang Wang wrote: > > +1 > > > > On Wed, Apr 27, 2016 at 1:21 PM, Ewen Cheslack-Postava > > > > wrote: > > > > > +1 > > > > > > On Thu, Apr 21, 2016 at 10:30 AM, Liquan Pei

Re: [VOTE] KIP-56 Allow cross origin HTTP requests on all HTTP methods

+1 -Harsha On Wed, Apr 27, 2016, at 01:29 PM, Guozhang Wang wrote: > +1 > > On Wed, Apr 27, 2016 at 1:21 PM, Ewen Cheslack-Postava > > wrote: > > > +1 > > > > On Thu, Apr 21, 2016 at 10:30 AM, Liquan Pei wrote: > > > > > Hi > > > > > > I would like to start vote on KIP-56. > > > > > > > > > >

Re: [VOTE] KIP-50: Move Authorizer to o.a.k.common package - Round 2

+1. On Wed, Apr 27, 2016 at 12:58 PM, Ewen Cheslack-Postava wrote: > +1 > > On Tue, Apr 26, 2016 at 8:20 PM, Harsha wrote: > > > +1 > > -Harsha > > > > On Mon, Apr 25, 2016, at 10:34 AM, Grant Henke wrote: > > > +1 (non-binding) > > > > > > On Mon, Apr 25, 2016 at 12:30 PM, Gwen Shapira > > wr

Re: [VOTE] KIP-56 Allow cross origin HTTP requests on all HTTP methods

+1 On Wed, Apr 27, 2016 at 1:21 PM, Ewen Cheslack-Postava wrote: > +1 > > On Thu, Apr 21, 2016 at 10:30 AM, Liquan Pei wrote: > > > Hi > > > > I would like to start vote on KIP-56. > > > > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-56%3A+Allow+cross+origin+HTTP+requests+on+all+

Re: [VOTE] KIP-56 Allow cross origin HTTP requests on all HTTP methods

+1 On Thu, Apr 21, 2016 at 10:30 AM, Liquan Pei wrote: > Hi > > I would like to start vote on KIP-56. > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-56%3A+Allow+cross+origin+HTTP+requests+on+all+HTTP+methods > > Thanks, > > -- > Liquan Pei > Software Engineer, Confluent Inc

Re: [VOTE] KIP-56 Allow cross origin HTTP requests on all HTTP methods

+1 On Thu, Apr 21, 2016 at 10:30 AM, Liquan Pei wrote: > Hi > > I would like to start vote on KIP-56. > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-56%3A+Allow+cross+origin+HTTP+requests+on+all+HTTP+methods > > Thanks, > > -- > Liquan Pei > Software Engineer, Confluent Inc > --

[jira] [Updated] (KAFKA-3618) Handle ApiVersionRequest before SASL handshake

[ https://issues.apache.org/jira/browse/KAFKA-3618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-3618: -- Status: Patch Available (was: Open) > Handle ApiVersionRequest before SASL handshake >

Re: [VOTE] KIP-50: Move Authorizer to o.a.k.common package - Round 2

+1 On Tue, Apr 26, 2016 at 8:20 PM, Harsha wrote: > +1 > -Harsha > > On Mon, Apr 25, 2016, at 10:34 AM, Grant Henke wrote: > > +1 (non-binding) > > > > On Mon, Apr 25, 2016 at 12:30 PM, Gwen Shapira > wrote: > > > > > +1 > > > > > > On Mon, Apr 25, 2016 at 10:04 AM, Ashish Singh > > > wrote: >

[jira] [Commented] (KAFKA-3618) Handle ApiVersionRequest before SASL handshake

[ https://issues.apache.org/jira/browse/KAFKA-3618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15260826#comment-15260826 ] Rajini Sivaram commented on KAFKA-3618: --- [~ijuma] Thank you, I have submitted a PR

[GitHub] kafka pull request: Kafka 3618: Handle ApiVersionsRequest before S...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/1276 Kafka 3618: Handle ApiVersionsRequest before SASL authentication Server-side implementation and tests for handling ApiVersionsRequest before SaslHandshakeRequest. You can merge this pull requ

[GitHub] kafka pull request: 0.10.0

Github user nikhilbhide closed the pull request at: https://github.com/apache/kafka/pull/1142 --- 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] [Commented] (KAFKA-3621) Add tests for ApiVersionRequest/Response

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

[GitHub] kafka pull request: KAFKA-3621: Add tests for ApiVersionRequest/Re...

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/1275 KAFKA-3621: Add tests for ApiVersionRequest/Response You can merge this pull request into a Git repository by running: $ git pull https://github.com/SinghAsDev/kafka KAFKA-3621 Alternative

[jira] [Commented] (KAFKA-3618) Handle ApiVersionRequest before SASL handshake

[ https://issues.apache.org/jira/browse/KAFKA-3618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15260770#comment-15260770 ] Ismael Juma commented on KAFKA-3618: Thanks [~rsivaram]. KAFKA-3307 has now been merge

Re: No Heartbeat request on commit

Hi Vinay, Answers below: 1) Is it correct to say that each commitSync will trigger a HeartBeatTask? > If there is no hear beat sent in past since specified heartbeat interval > then i should see a successful heartbeat response or failure message in > logs near to commitSync success log? Not qu

[jira] [Commented] (KAFKA-3307) Add ApiVersion request/response and server side handling.

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

[GitHub] kafka pull request: KAFKA-3307: Add ApiVersions Request/Response a...

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

[jira] [Updated] (KAFKA-3307) Add ApiVersion request/response and server side handling.

[ https://issues.apache.org/jira/browse/KAFKA-3307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3307: Resolution: Fixed Fix Version/s: (was: 0.10.0.0) 0.10.1.0 St

[jira] [Commented] (KAFKA-3629) KStreamImpl.to(...) throws NPE when the value SerDe is null

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

[jira] [Updated] (KAFKA-3629) KStreamImpl.to(...) throws NPE when the value SerDe is null

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

[GitHub] kafka pull request: KAFKA-3629 KStreamImpl.to(...) throws NPE when...

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

[GitHub] kafka pull request: Git ignore idea's specific /out/ and .DS_Store...

Github user SinghAsDev closed the pull request at: https://github.com/apache/kafka/pull/1274 --- 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] [Updated] (KAFKA-3630) Consider auto closing outdated pull requests

[ https://issues.apache.org/jira/browse/KAFKA-3630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3630: --- Description: Currently we don't have access to close pull requests and the list of open pull requests

[jira] [Commented] (KAFKA-3630) Consider auto closing outdated pull requests

[ https://issues.apache.org/jira/browse/KAFKA-3630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15260555#comment-15260555 ] Grant Henke commented on KAFKA-3630: [~ijuma] I agree a bit longer might be better. I

[jira] [Commented] (KAFKA-3630) Consider auto closing outdated pull requests

[ https://issues.apache.org/jira/browse/KAFKA-3630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15260523#comment-15260523 ] Ismael Juma commented on KAFKA-3630: It sounds like a good idea although 15 days seems

[jira] [Resolved] (KAFKA-3469) kafka-topics lock down znodes with user principal when zk security is enabled.

[ https://issues.apache.org/jira/browse/KAFKA-3469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh resolved KAFKA-3469. --- Resolution: Information Provided Had an offline discussion with [~fpj] and it seems we can hav

[GitHub] kafka pull request: Git ignore idea's specific /out/ and .DS_Store...

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/1274 Git ignore idea's specific /out/ and .DS_Store. You can merge this pull request into a Git repository by running: $ git pull https://github.com/SinghAsDev/kafka MinorGitignore Alternativel

[jira] [Created] (KAFKA-3630) Consider auto closing outdated pull requests

Grant Henke created KAFKA-3630: -- Summary: Consider auto closing outdated pull requests Key: KAFKA-3630 URL: https://issues.apache.org/jira/browse/KAFKA-3630 Project: Kafka Issue Type: Improvemen

[jira] [Commented] (KAFKA-3618) Handle ApiVersionRequest before SASL handshake

[ https://issues.apache.org/jira/browse/KAFKA-3618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15260412#comment-15260412 ] Rajini Sivaram commented on KAFKA-3618: --- Server-side code for handling ApiVersionsRe

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

See

Re: GroupCoordinatorNotAvailableException, consumer error on poll request

Problem solved! I had to reconfigure some brokers, to cleanup the configuration and metadata in __consumer offset. Thanks Jason On 26/04/16 23:06, Jason Gustafson wrote: Hey Jose, That error could indicate that one of the partitions of the __consumer_offsets topic has no leader. The group

Jenkins build is back to normal : kafka-trunk-jdk8 #558

See

[jira] [Resolved] (KAFKA-2658) Implement SASL/PLAIN

[ https://issues.apache.org/jira/browse/KAFKA-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-2658. --- Resolution: Duplicate This was done under KAFKA-3149. > Implement SASL/PLAIN > --

Re: No Heartbeat request on commit

Hey, I am working on a simplified test case to check if there is any issue in my code. Just to make sure that any of my assumptions are not wrong, it will be great if you can please help me in finding answers to following queries:- 1) Is it correct to say that each commitSync will trigger a Hear

[jira] [Commented] (KAFKA-3618) Handle ApiVersionRequest before SASL handshake

[ https://issues.apache.org/jira/browse/KAFKA-3618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15260201#comment-15260201 ] Rajini Sivaram commented on KAFKA-3618: --- [~junrao] [~ijuma] I have the server-side c

[jira] [Commented] (KAFKA-3580) improve error logging in ReplicaFetchThread with oversized message

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

[jira] [Updated] (KAFKA-3580) improve error logging in ReplicaFetchThread with oversized message

[ https://issues.apache.org/jira/browse/KAFKA-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3580: --- Resolution: Fixed Fix Version/s: 0.10.0.0 Status: Resolved (was: Patch Available) I

[GitHub] kafka pull request: KAFKA-3580; improve error logging in ReplicaFe...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1237 --- 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-3629) KStreamImpl.to(...) throws NPE when the value SerDe is null

[ https://issues.apache.org/jira/browse/KAFKA-3629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3629: --- Status: Patch Available (was: Open) > KStreamImpl.to(...) throws NPE when the value SerDe is

[jira] [Updated] (KAFKA-3617) Add unit tests for SASL authentication

[ https://issues.apache.org/jira/browse/KAFKA-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-3617: -- Status: Patch Available (was: Open) > Add unit tests for SASL authentication >

[jira] [Commented] (KAFKA-3617) Add unit tests for SASL authentication

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

[GitHub] kafka pull request: KAFKA-3617: Unit tests for SASL authenticator

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/1273 KAFKA-3617: Unit tests for SASL authenticator Unit tests for SASL authenticator, tests for SASL/PLAIN and multiple mechanisms, authorization test for SASL/PLAIN You can merge this pull reques

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

See Changes: [ismael] KAFKA-3406; Update CommonClientConfigs.RETRY_BACKOFF_MS_DOC doc string -- [...truncated 2527 lines...] kafka.api.SaslSslConsumerTest > testPartitionReassignmentCallback PAS

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

See Changes: [ismael] KAFKA-3406; Update CommonClientConfigs.RETRY_BACKOFF_MS_DOC doc string -- [...truncated 1650 lines...] kafka.log.OffsetIndexTest > appendTooMany PASSED kafka.log.OffsetIn

[jira] [Commented] (KAFKA-3629) KStreamImpl.to(...) throws NPE when the value SerDe is null

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

[GitHub] kafka pull request: KAFKA-3629 KStreamImpl.to(...) throws NPE when...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/1272 KAFKA-3629 KStreamImpl.to(...) throws NPE when the value SerDe is null @guozhangwang You can merge this pull request into a Git repository by running: $ git pull https://github.com/dguy/kafka kst

[jira] [Created] (KAFKA-3629) KStreamImpl.to(...) throws NPE when the value SerDe is null

Damian Guy created KAFKA-3629: - Summary: KStreamImpl.to(...) throws NPE when the value SerDe is null Key: KAFKA-3629 URL: https://issues.apache.org/jira/browse/KAFKA-3629 Project: Kafka Issue Ty

  1   2   >