[jira] [Created] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

Hitoshi Ozawa created KAFKA-2703: Summary: SimpleConsumer.scala is declared as threadsafe but is not Key: KAFKA-2703 URL: https://issues.apache.org/jira/browse/KAFKA-2703 Project: Kafka Issue

[jira] [Updated] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

[ https://issues.apache.org/jira/browse/KAFKA-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2703: - Status: Patch Available (was: Open) The patch just adds @throws annotations to methods to make th

[jira] [Issue Comment Deleted] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

[ https://issues.apache.org/jira/browse/KAFKA-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2703: - Comment: was deleted (was: The patch just adds @throws annotations to methods to make them thread

[jira] [Updated] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

[ https://issues.apache.org/jira/browse/KAFKA-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2703: - Status: Open (was: Patch Available) > SimpleConsumer.scala is declared as threadsafe but is not >

[jira] [Updated] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

[ https://issues.apache.org/jira/browse/KAFKA-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2703: - Status: Patch Available (was: Open) I've made a pull request for the patch. https://github.com/ho

[jira] [Updated] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

[ https://issues.apache.org/jira/browse/KAFKA-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2703: - Attachment: simpleconsumer.patch Patch to make SimpleConsumer.scale threadsafe > SimpleConsumer.s

[jira] [Created] (KAFKA-2704) SimpleConsumer should throw InterruptedException when interrupted

Hitoshi Ozawa created KAFKA-2704: Summary: SimpleConsumer should throw InterruptedException when interrupted Key: KAFKA-2704 URL: https://issues.apache.org/jira/browse/KAFKA-2704 Project: Kafka

[jira] [Updated] (KAFKA-2704) SimpleConsumer should throw InterruptedException when interrupted

[ https://issues.apache.org/jira/browse/KAFKA-2704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2704: - Attachment: simpleconsumer_2.patch A patch to throw InterruptedException when interrupted > Simpl

[jira] [Updated] (KAFKA-2704) SimpleConsumer should throw InterruptedException when interrupted

[ https://issues.apache.org/jira/browse/KAFKA-2704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2704: - Reviewer: Aditya A Auradkar Status: Patch Available (was: Open) A patch to throw throw Inte

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

See

[jira] [Created] (KAFKA-2705) Remove static JAAS config file for ZK auth tests

Flavio Junqueira created KAFKA-2705: --- Summary: Remove static JAAS config file for ZK auth tests Key: KAFKA-2705 URL: https://issues.apache.org/jira/browse/KAFKA-2705 Project: Kafka Issue Ty

[GitHub] kafka pull request: KAFKA-2705: Remove static JAAS config file for...

GitHub user fpj opened a pull request: https://github.com/apache/kafka/pull/380 KAFKA-2705: Remove static JAAS config file for ZK auth tests Remove static login config file. You can merge this pull request into a Git repository by running: $ git pull https://github.com/fpj/kafk

[jira] [Commented] (KAFKA-2705) Remove static JAAS config file for ZK auth tests

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

[jira] [Resolved] (KAFKA-2598) Add Test with authorizer for producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-2598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2598. Resolution: Fixed Issue resolved by pull request 300 [https://github.com/apache/kafka/pull/300] > Add Test

[jira] [Commented] (KAFKA-2598) Add Test with authorizer for producer and consumer

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

[GitHub] kafka pull request: KAFKA-2598: Adding integration test for the au...

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

Re: [DISCUSS] KIP-40 - Extend GroupMetadata request to return group and member status

I like Jun's suggestion of adding ListGroups and DescribeGroup. It keeps the abstractions simple and avoids overloading existing requests. On Wed, Oct 28, 2015 at 8:08 PM, Jason Gustafson wrote: > Hey Jun, > > Thanks for taking a look at this. Initially the thought was to make > GroupMetadataReq

[jira] [Assigned] (KAFKA-2691) Improve handling of authorization failure during metadata refresh

[ https://issues.apache.org/jira/browse/KAFKA-2691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2691: -- Assignee: Jason Gustafson > Improve handling of authorization failure during metadata r

[jira] [Commented] (KAFKA-2502) Quotas documentation for 0.8.3

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

[GitHub] kafka pull request: KAFKA-2502 - Documentation for quotas

GitHub user auradkar opened a pull request: https://github.com/apache/kafka/pull/381 KAFKA-2502 - Documentation for quotas Followed the approach specified here: https://issues.apache.org/jira/browse/KAFKA-2502 I also made a minor fix to ConfigCommand to expose the right options

[jira] [Commented] (KAFKA-2502) Quotas documentation for 0.8.3

[ https://issues.apache.org/jira/browse/KAFKA-2502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14980712#comment-14980712 ] Aditya Auradkar commented on KAFKA-2502: [~gwenshap] - Published a patch. Please t

[jira] [Commented] (KAFKA-2674) ConsumerRebalanceListener.onPartitionsRevoked() is not called on consumer close

[ https://issues.apache.org/jira/browse/KAFKA-2674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14980737#comment-14980737 ] Jiangjie Qin commented on KAFKA-2674: - [~hachikuji] I am wondering do we want to avoid

Re: [DISCUSS] KIP-40 - Extend GroupMetadata request to return group and member status

Hi All, I've updated the KIP for ListGroups and DescribeGroup. This does simplify things quite a bit. Since this is a blocker for 0.9 and there doesn't seem to be any major objections, let's go ahead and start the vote. Minor issues with the schemas can be addressed on the JIRA. Thanks, Jason

[jira] [Created] (KAFKA-2706) Make state stores first class citizens in the processor DAG

Yasuhiro Matsuda created KAFKA-2706: --- Summary: Make state stores first class citizens in the processor DAG Key: KAFKA-2706 URL: https://issues.apache.org/jira/browse/KAFKA-2706 Project: Kafka

[jira] [Updated] (KAFKA-2707) Make KStream processor names deterministic

[ https://issues.apache.org/jira/browse/KAFKA-2707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yasuhiro Matsuda updated KAFKA-2707: Summary: Make KStream processor names deterministic (was: Make KStream processor names dete

[jira] [Created] (KAFKA-2707) Make KStream processor names deteministic

Yasuhiro Matsuda created KAFKA-2707: --- Summary: Make KStream processor names deteministic Key: KAFKA-2707 URL: https://issues.apache.org/jira/browse/KAFKA-2707 Project: Kafka Issue Type: Sub

Re: [DISCUSS] KIP-40 - Extend GroupMetadata request to return group and member status

Forgot to include a link to the changed KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-40%3A+ListGroups+and+DescribeGroup -Jason On Thu, Oct 29, 2015 at 9:43 AM, Jason Gustafson wrote: > Hi All, > > I've updated the KIP for ListGroups and DescribeGroup. This does simplify > things q

[jira] [Updated] (KAFKA-2707) Make KStream processor names deterministic

[ https://issues.apache.org/jira/browse/KAFKA-2707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yasuhiro Matsuda updated KAFKA-2707: Description: Currently KStream processor names are generated from AtomicInteger static membe

[jira] [Updated] (KAFKA-2644) Run relevant ducktape tests with SASL_PLAINTEXT and SASL_SSL

[ https://issues.apache.org/jira/browse/KAFKA-2644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2644: Priority: Blocker (was: Critical) > Run relevant ducktape tests with SASL_PLAINTEXT and SASL_SSL >

[jira] [Commented] (KAFKA-2702) ConfigDef toHtmlTable() sorts in a way that is a bit confusing

[ https://issues.apache.org/jira/browse/KAFKA-2702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14980817#comment-14980817 ] Grant Henke commented on KAFKA-2702: [~jkreps] You are right, that _required_ was adde

[jira] [Resolved] (KAFKA-2417) Ducktape tests for SSL/TLS

[ https://issues.apache.org/jira/browse/KAFKA-2417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2417. - Resolution: Fixed Closing - this is tracked in KAFKA-2644, and we can add additional JIRA for spe

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

See Changes: [junrao] KAFKA-2598; Adding integration test for the authorizer at API level. ��� -- [...truncated 3045 lines...] kafka.integration.PrimitiveApiTest > testDefaultEncoderProducerAnd

[jira] [Commented] (KAFKA-2017) Persist Coordinator State for Coordinator Failover

[ https://issues.apache.org/jira/browse/KAFKA-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14980895#comment-14980895 ] Jiangjie Qin commented on KAFKA-2017: - [~guozhang] I think the approach works. It migh

[GitHub] kafka pull request: KAFKA-2449: Docs: Automatically generate docum...

GitHub user gwenshap opened a pull request: https://github.com/apache/kafka/pull/382 KAFKA-2449: Docs: Automatically generate documentation from config classes …the way we always planned to You can merge this pull request into a Git repository by running: $ git pull https://g

[jira] [Commented] (KAFKA-2449) Update mirror maker (MirrorMaker) docs

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

[jira] [Commented] (KAFKA-2449) Update mirror maker (MirrorMaker) docs

[ https://issues.apache.org/jira/browse/KAFKA-2449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14980952#comment-14980952 ] Gwen Shapira commented on KAFKA-2449: - Sorry, ignore new PR. Wrong JIRA... > Update m

[jira] [Updated] (KAFKA-2666) Docs: Automatically generate documentation from config classes

[ https://issues.apache.org/jira/browse/KAFKA-2666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2666: Assignee: Gwen Shapira Status: Patch Available (was: Open) > Docs: Automatically generate doc

[jira] [Commented] (KAFKA-2666) Docs: Automatically generate documentation from config classes

[ https://issues.apache.org/jira/browse/KAFKA-2666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14980957#comment-14980957 ] Gwen Shapira commented on KAFKA-2666: - Misnamed PR and it didn't get auto-posted, but

[GitHub] kafka pull request: MINOR: update to correct clock skew

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/383 MINOR: update to correct clock skew @ewencp Updated the provisioning script to install ntp daemon. You can merge this pull request into a Git repository by running: $ git pull https://gith

[GitHub] kafka pull request: KAFKA-2663, KAFKA-2664 - [Minor] Bugfixes

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/369 --- 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] [Resolved] (KAFKA-2663) Add quota-delay time to request processing time break-up

[ https://issues.apache.org/jira/browse/KAFKA-2663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy resolved KAFKA-2663. --- Resolution: Fixed Fix Version/s: (was: 0.9.0.1) 0.9.0.0 Issue resolved b

[jira] [Commented] (KAFKA-2663) Add quota-delay time to request processing time break-up

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

[jira] [Resolved] (KAFKA-2664) Adding a new metric with several pre-existing metrics is very expensive

[ https://issues.apache.org/jira/browse/KAFKA-2664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy resolved KAFKA-2664. --- Resolution: Fixed Fix Version/s: (was: 0.9.0.1) 0.9.0.0 Issue resolved b

[GitHub] kafka pull request: KAFKA-2705: Remove static JAAS config file for...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/380 --- 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] [Resolved] (KAFKA-2705) Remove static JAAS config file for ZK auth tests

[ https://issues.apache.org/jira/browse/KAFKA-2705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2705. Resolution: Fixed Issue resolved by pull request 380 [https://github.com/apache/kafka/pull/380] > Remove st

[jira] [Commented] (KAFKA-2705) Remove static JAAS config file for ZK auth tests

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

Re: [VOTE] KIP-40 ListGroups and DescribeGroup

+1 (non-binding) On Thu, Oct 29, 2015 at 12:02 PM, Jason Gustafson wrote: > Since we're crunching a little on the 0.9 release, I'd like to begin voting > for KIP-40. If you agree overall, but have minor objections with the > schemas, we can discuss them on the JIRA. > > Summary: Add ListGroups a

[VOTE] KIP-40 ListGroups and DescribeGroup

Since we're crunching a little on the 0.9 release, I'd like to begin voting for KIP-40. If you agree overall, but have minor objections with the schemas, we can discuss them on the JIRA. Summary: Add ListGroups and DescribeGroup APIs for admin tooling to view consumer groups and status. KIP: https

[jira] [Created] (KAFKA-2708) 29.10.2015 последний охотник на ведьм 2015 смотреть онлайн полный фильм hd 720

bobfilm created KAFKA-2708: -- Summary: 29.10.2015 последний охотник на ведьм 2015 смотреть онлайн полный фильм hd 720 Key: KAFKA-2708 URL: https://issues.apache.org/jira/browse/KAFKA-2708 Project: Kafka

[jira] [Created] (KAFKA-2709) марсианин 2015 смотреть онлайн полный фильм hd 720 на !АЙПАД!

bobfilm created KAFKA-2709: -- Summary: марсианин 2015 смотреть онлайн полный фильм hd 720 на !АЙПАД! Key: KAFKA-2709 URL: https://issues.apache.org/jira/browse/KAFKA-2709 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-2710) багровый пик 2015 смотреть онлайн полный фильм в хорошем качестве 11п2

bobfilm created KAFKA-2710: -- Summary: багровый пик 2015 смотреть онлайн полный фильм в хорошем качестве 11п2 Key: KAFKA-2710 URL: https://issues.apache.org/jira/browse/KAFKA-2710 Project: Kafka Iss

[jira] [Commented] (KAFKA-2017) Persist Coordinator State for Coordinator Failover

[ https://issues.apache.org/jira/browse/KAFKA-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14981140#comment-14981140 ] Guozhang Wang commented on KAFKA-2017: -- Rep [~becket_qin]: 1) Consumer also monitor

[jira] [Resolved] (KAFKA-2710) багровый пик 2015 смотреть онлайн полный фильм в хорошем качестве 11п2

[ https://issues.apache.org/jira/browse/KAFKA-2710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman resolved KAFKA-2710. - Resolution: Won't Fix > багровый пик 2015 смотреть онлайн полный фильм в хорошем качестве 11п2 > -

Re: [VOTE] KIP-40 ListGroups and DescribeGroup

+1 On Thu, Oct 29, 2015 at 12:02 PM, Jason Gustafson wrote: > Since we're crunching a little on the 0.9 release, I'd like to begin voting > for KIP-40. If you agree overall, but have minor objections with the > schemas, we can discuss them on the JIRA. > > Summary: Add ListGroups and DescribeGro

Re: [VOTE] KIP-40 ListGroups and DescribeGroup

+1 (binding) On Thu, Oct 29, 2015 at 12:04 PM, Ashish Singh wrote: > +1 (non-binding) > > On Thu, Oct 29, 2015 at 12:02 PM, Jason Gustafson > wrote: > > > Since we're crunching a little on the 0.9 release, I'd like to begin > voting > > for KIP-40. If you agree overall, but have minor objection

Re: [VOTE] KIP-40 ListGroups and DescribeGroup

+1 (non-binding) On Thu, Oct 29, 2015 at 1:00 PM, Guozhang Wang wrote: > +1 (binding) > > On Thu, Oct 29, 2015 at 12:04 PM, Ashish Singh > wrote: > > > +1 (non-binding) > > > > On Thu, Oct 29, 2015 at 12:02 PM, Jason Gustafson > > wrote: > > > > > Since we're crunching a little on the 0.9 rele

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

See Changes: [jjkoshy] KAFKA-2663 KAFKA-2664; Add quota-delay time to request processing time [junrao] KAFKA-2705; Remove static JAAS config file for ZK auth tests [jjkoshy] KAFKA-2663; Trivial follow-up to edit comments

[jira] [Commented] (KAFKA-2681) SASL authentication in official docs

[ https://issues.apache.org/jira/browse/KAFKA-2681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14981269#comment-14981269 ] Jun Rao commented on KAFKA-2681: [~sriharsha], have you completed the SASL wiki yet? The 0

[jira] [Updated] (KAFKA-2681) SASL authentication in official docs

[ https://issues.apache.org/jira/browse/KAFKA-2681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2681: --- Priority: Blocker (was: Major) > SASL authentication in official docs >

Re: [VOTE] KIP-40 ListGroups and DescribeGroup

+1 (non-binding) On Thu, Oct 29, 2015 at 1:03 PM, Jiangjie Qin wrote: > +1 (non-binding) > > On Thu, Oct 29, 2015 at 1:00 PM, Guozhang Wang wrote: > > > +1 (binding) > > > > On Thu, Oct 29, 2015 at 12:04 PM, Ashish Singh > > wrote: > > > > > +1 (non-binding) > > > > > > On Thu, Oct 29, 2015 at

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

See Changes: [jjkoshy] KAFKA-2663 KAFKA-2664; Add quota-delay time to request processing time [junrao] KAFKA-2705; Remove static JAAS config file for ZK auth tests [jjkoshy] KAFKA-2663; Trivial follow-up to edit comments -

[jira] [Commented] (KAFKA-2675) SASL/Kerberos follow-up

[ https://issues.apache.org/jira/browse/KAFKA-2675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14981303#comment-14981303 ] Jun Rao commented on KAFKA-2675: [~sriharsha], could you explain a bit how cross realm con

Re: [VOTE] KIP-40 ListGroups and DescribeGroup

+1 (binding) On Thu, Oct 29, 2015 at 2:14 PM, Onur Karaman wrote: > +1 (non-binding) > > On Thu, Oct 29, 2015 at 1:03 PM, Jiangjie Qin wrote: > > > +1 (non-binding) > > > > On Thu, Oct 29, 2015 at 1:00 PM, Guozhang Wang > wrote: > > > > > +1 (binding) > > > > > > On Thu, Oct 29, 2015 at 12:04

Re: [VOTE] KIP-40 ListGroups and DescribeGroup

Just a minor suggestion. Perhaps DescribeGroupRequest can take an array of groupIds instead of a single one. This allows the clients to batch description on multiple groups if needed. Otherwise, +1 from me too. Thanks, Jun On Thu, Oct 29, 2015 at 12:02 PM, Jason Gustafson wrote: > Since we're

[jira] [Updated] (KAFKA-2687) Allow GroupMetadataRequest to return member metadata when received by group coordinator

[ https://issues.apache.org/jira/browse/KAFKA-2687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2687: --- Description: Since the new consumer currently has no persistence in Zookeeper (pending outcome of KAFKA-2017)

[jira] [Commented] (KAFKA-2687) Allow GroupMetadataRequest to return member metadata when received by group coordinator

[ https://issues.apache.org/jira/browse/KAFKA-2687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14981394#comment-14981394 ] Jun Rao commented on KAFKA-2687: With https://cwiki.apache.org/confluence/display/KAFKA/K

[jira] [Commented] (KAFKA-2687) Allow GroupMetadataRequest to return member metadata when received by group coordinator

[ https://issues.apache.org/jira/browse/KAFKA-2687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14981400#comment-14981400 ] Jason Gustafson commented on KAFKA-2687: [~junrao] Sounds good. That's exactly wha

[GitHub] kafka pull request: MINOR: Added integration tests for exceptional...

GitHub user apovzner opened a pull request: https://github.com/apache/kafka/pull/384 MINOR: Added integration tests for exceptional cases in fetching 1. When reset policy is NONE, verify that NoOffsetForPartitionException is thrown if no initial position is set. Verify that OffsetOu

[jira] [Updated] (KAFKA-2680) Zookeeper SASL check prevents any SASL code being run with IBM JDK

[ https://issues.apache.org/jira/browse/KAFKA-2680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2680: --- Reviewer: Jun Rao > Zookeeper SASL check prevents any SASL code being run with IBM JDK > -

[jira] [Updated] (KAFKA-2644) Run relevant ducktape tests with SASL_PLAINTEXT and SASL_SSL

[ https://issues.apache.org/jira/browse/KAFKA-2644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2644: --- Reviewer: Jun Rao > Run relevant ducktape tests with SASL_PLAINTEXT and SASL_SSL > ---

[GitHub] kafka pull request: Update which makes kafkatest services useable ...

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/385 Update which makes kafkatest services useable by external dependencies @ewencp Some *.properties files were missing from `kafkatest` package I've tested this change on aws with confluen

[GitHub] kafka pull request: MINOR: update to correct clock skew

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

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

See -- [...truncated 3873 lines...] kafka.coordinator.MemberMetadataTest > testVoteRaisesOnNoSupportedProtocols PASSED kafka.log.BrokerCompressionTest > testBrokerSideCompression[0] PASSED kafka.log.Br

[GitHub] kafka pull request: KAFKA-2017: Persist Group Metadata and Assignm...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/386 KAFKA-2017: Persist Group Metadata and Assignment before Responding You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K2017

[jira] [Commented] (KAFKA-2017) Persist Coordinator State for Coordinator Failover

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

[GitHub] kafka pull request: KAFKA-2706: make state stores first class citi...

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/387 KAFKA-2706: make state stores first class citizens in the processor topology * Added StateStoreSupplier * StateStore * Added init(ProcessorContext context) method * TopologyBuilder

[jira] [Commented] (KAFKA-2706) Make state stores first class citizens in the processor DAG

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

[jira] [Commented] (KAFKA-2702) ConfigDef toHtmlTable() sorts in a way that is a bit confusing

[ https://issues.apache.org/jira/browse/KAFKA-2702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14981631#comment-14981631 ] Gwen Shapira commented on KAFKA-2702: - This needs some cleanup - because required=true

[jira] [Created] (KAFKA-2711) SaslClientAuthenticator no longer needs KerberosNameParser in constructor

Jun Rao created KAFKA-2711: -- Summary: SaslClientAuthenticator no longer needs KerberosNameParser in constructor Key: KAFKA-2711 URL: https://issues.apache.org/jira/browse/KAFKA-2711 Project: Kafka

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

See Changes: [cshapi] MINOR: update to correct clock skew -- [...truncated 3872 lines...] kafka.coordinator.MemberMetadataTest > testVoteRaisesOnNoSupportedProtocols PASSED kafka.log.BrokerComp

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

See -- [...truncated 362 lines...] :kafka-trunk-jdk8:log4j-appender:compileJava UP-TO-DATE :kafka-trunk-jdk8:log4j-appender:processResources UP-TO-DATE :kafka-trunk-jdk8:log4j-appender:classes UP-TO-DATE :

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

See

[jira] [Resolved] (KAFKA-2502) Quotas documentation for 0.8.3

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

[GitHub] kafka pull request: KAFKA-2502 - Documentation for quotas

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/381 --- 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] [Commented] (KAFKA-2502) Quotas documentation for 0.8.3

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

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

See Changes: [cshapi] KAFKA-2502; Documentation for quotas -- [...truncated 326 lines...] :kafka-trunk-jdk7:clients:createVersionFile :kafka-trunk-jdk7:clients:jar UP-TO-DATE :kafka-trunk-jdk7:cl

[jira] [Updated] (KAFKA-2704) SimpleConsumer should throw InterruptedException when interrupted

[ https://issues.apache.org/jira/browse/KAFKA-2704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2704: - Reviewer: Jun Rao (was: Aditya A Auradkar) > SimpleConsumer should throw InterruptedException whe

[jira] [Updated] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

[ https://issues.apache.org/jira/browse/KAFKA-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2703: - Reviewer: Jun Rao > SimpleConsumer.scala is declared as threadsafe but is not > --

[jira] [Updated] (KAFKA-2704) SimpleConsumer should throw InterruptedException when interrupted

[ https://issues.apache.org/jira/browse/KAFKA-2704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2704: - Reviewer: Gwen Shapira (was: Jun Rao) > SimpleConsumer should throw InterruptedException when int

[jira] [Updated] (KAFKA-2703) SimpleConsumer.scala is declared as threadsafe but is not

[ https://issues.apache.org/jira/browse/KAFKA-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hitoshi Ozawa updated KAFKA-2703: - Reviewer: Gwen Shapira (was: Jun Rao) > SimpleConsumer.scala is declared as threadsafe but is not

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

See Changes: [cshapi] KAFKA-2502; Documentation for quotas -- [...truncated 363 lines...] :kafka-trunk-jdk8:log4j-appender:compileJava UP-TO-DATE :kafka-trunk-jdk8:log4j-appender:processResources

Re: [VOTE] KIP-40 ListGroups and DescribeGroup

+1 (non-binding) -Ewen On Thu, Oct 29, 2015 at 2:34 PM, Jun Rao wrote: > Just a minor suggestion. Perhaps DescribeGroupRequest can take an array of > groupIds instead of a single one. This allows the clients to batch > description on multiple groups if needed. > > Otherwise, +1 from me too. > >

[jira] [Commented] (KAFKA-2711) SaslClientAuthenticator no longer needs KerberosNameParser in constructor

[ https://issues.apache.org/jira/browse/KAFKA-2711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14981805#comment-14981805 ] Ismael Juma commented on KAFKA-2711: I'm not sure I understand. `clientPrincipalName`

[jira] [Commented] (KAFKA-2711) SaslClientAuthenticator no longer needs KerberosNameParser in constructor

[ https://issues.apache.org/jira/browse/KAFKA-2711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14981954#comment-14981954 ] Jun Rao commented on KAFKA-2711: Yes, you are right. clientPrincipalName is still used. My

[jira] [Created] (KAFKA-2712) Reassignment Partition Tool Issue

Kiran created KAFKA-2712: Summary: Reassignment Partition Tool Issue Key: KAFKA-2712 URL: https://issues.apache.org/jira/browse/KAFKA-2712 Project: Kafka Issue Type: Bug Components: admin