[jira] [Created] (KAFKA-2842) BrokerEndPoint regex does't support hostname with _

Sachin Pasalkar created KAFKA-2842: -- Summary: BrokerEndPoint regex does't support hostname with _ Key: KAFKA-2842 URL: https://issues.apache.org/jira/browse/KAFKA-2842 Project: Kafka Issue T

[jira] [Commented] (KAFKA-2842) BrokerEndPoint regex does't support hostname with _

[ https://issues.apache.org/jira/browse/KAFKA-2842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15006589#comment-15006589 ] Ismael Juma commented on KAFKA-2842: I think this is intentional because of RFC952:

[jira] [Updated] (KAFKA-2757) Consolidate BrokerEndPoint and EndPoint

[ https://issues.apache.org/jira/browse/KAFKA-2757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2757: --- Summary: Consolidate BrokerEndPoint and EndPoint (was: Consoliate BrokerEndPoint and EndPoint) > Con

[jira] [Commented] (KAFKA-2842) BrokerEndPoint regex does't support hostname with _

[ https://issues.apache.org/jira/browse/KAFKA-2842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15006593#comment-15006593 ] Sachin Pasalkar commented on KAFKA-2842: Ohh, thanks for this update :) > BrokerE

[GitHub] kafka pull request: KAFKA-2824: MiniKDC based tests don't run in V...

Github user benstopford closed the pull request at: https://github.com/apache/kafka/pull/520 --- 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-2824) MiniKDC based tests don't run in VirtualBox

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

[jira] [Created] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

wanghongjiang created KAFKA-2843: Summary: when consumer got empty messageset, fetchResponse.highWatermark != current_offset? Key: KAFKA-2843 URL: https://issues.apache.org/jira/browse/KAFKA-2843 Proj

[jira] [Updated] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] netcafe updated KAFKA-2843: --- Description: I use simple consumer fetch message from brokers，when consumer got empty messageSet，e.g ： v

[jira] [Updated] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] netcafe updated KAFKA-2843: --- Description: I use simple consumer fetch message from brokers，when consumer got empty messageSet，e.g ： v

[jira] [Resolved] (KAFKA-2842) BrokerEndPoint regex does't support hostname with _

[ https://issues.apache.org/jira/browse/KAFKA-2842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2842. - Resolution: Not A Problem > BrokerEndPoint regex does't support hostname with _ >

[jira] [Assigned] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jin xing reassigned KAFKA-2843: --- Assignee: jin xing > when consumer got empty messageset, fetchResponse.highWatermark != > current_of

Re: setting up kafka github

Hi Mojhaha, You will not have access to the actual Apache Kafka repo. Everyone contributes via their own fork and asking for the changes to be pulled into (pull request) the Apache Kafka repo. The guide linked earlier is a great resource for the Github process. Thanks, Grant On Sat, Nov 14, 2015

[jira] [Updated] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] netcafe updated KAFKA-2843: --- Description: I use simple consumer fetch message from brokers，when consumer got empty messageSet，e.g ： v

Re: setting up kafka github

Hello, That answers my question. Thanks Mojhaha On Mon, Nov 16, 2015 at 7:55 PM, Grant Henke wrote: > Hi Mojhaha, > > You will not have access to the actual Apache Kafka repo. Everyone > contributes via their own fork and asking for the changes to be pulled into > (pull request) the Apache Kaf

[jira] [Updated] (KAFKA-2732) Add test cases with ZK Auth, SASL and SSL

[ https://issues.apache.org/jira/browse/KAFKA-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-2732: Description: Add test cases to verify the security functionality being added in 0.9. (was:

[jira] [Updated] (KAFKA-2732) Add test cases with ZK Auth, SASL and SSL

[ https://issues.apache.org/jira/browse/KAFKA-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-2732: Summary: Add test cases with ZK Auth, SASL and SSL (was: Add support for consumer test with

[jira] [Commented] (KAFKA-2841) Group metadata cache loading is not safe when reloading a partition

[ https://issues.apache.org/jira/browse/KAFKA-2841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007035#comment-15007035 ] Jun Rao commented on KAFKA-2841: I thought the current logic is that if a group is being u

[jira] [Commented] (KAFKA-2746) Add support for using ConsumerGroupCommand on secure install

[ https://issues.apache.org/jira/browse/KAFKA-2746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007047#comment-15007047 ] Jun Rao commented on KAFKA-2746: [~singhashish], do you have time to work on this today? I

[jira] [Updated] (KAFKA-2746) Add support for using ConsumerGroupCommand on secure install

[ https://issues.apache.org/jira/browse/KAFKA-2746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2746: --- Fix Version/s: 0.9.0.0 > Add support for using ConsumerGroupCommand on secure install > --

[jira] [Commented] (KAFKA-2841) Group metadata cache loading is not safe when reloading a partition

[ https://issues.apache.org/jira/browse/KAFKA-2841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007059#comment-15007059 ] Jason Gustafson commented on KAFKA-2841: [~junrao] That is correct. The problem is

[jira] [Created] (KAFKA-2844) Use different keyTab for client and server in SASL tests

Ismael Juma created KAFKA-2844: -- Summary: Use different keyTab for client and server in SASL tests Key: KAFKA-2844 URL: https://issues.apache.org/jira/browse/KAFKA-2844 Project: Kafka Issue Type

[GitHub] kafka pull request: KAFKA-2844; Separate keyTabs for sasl tests

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/533 KAFKA-2844; Separate keyTabs for sasl tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka separate-keytabs-for-sasl-tests Alternativ

[jira] [Commented] (KAFKA-2844) Use different keyTab for client and server in SASL tests

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

[jira] [Updated] (KAFKA-2844) Use different keyTab for client and server in SASL tests

[ https://issues.apache.org/jira/browse/KAFKA-2844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2844: --- Reviewer: Jun Rao Status: Patch Available (was: Open) > Use different keyTab for client and ser

[GitHub] kafka pull request: Kafka 2746

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/534 Kafka 2746 You can merge this pull request into a Git repository by running: $ git pull https://github.com/SinghAsDev/kafka KAFKA-2746 Alternatively you can review and apply these changes a

[jira] [Commented] (KAFKA-2746) Add support for using ConsumerGroupCommand on secure install

[ https://issues.apache.org/jira/browse/KAFKA-2746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007139#comment-15007139 ] Ashish K Singh commented on KAFKA-2746: --- [~junrao], [~ijuma] PR is up at https://git

[GitHub] kafka pull request: KAFKA-2811: add standby tasks

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/526 --- 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-2811) Add standby tasks

[ https://issues.apache.org/jira/browse/KAFKA-2811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2811. -- Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull request 526 [https://gith

[jira] [Commented] (KAFKA-2811) Add standby tasks

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

[GitHub] kafka pull request: MINOR: do not create a StandbyTask if there is...

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/535 MINOR: do not create a StandbyTask if there is no state store in the task @guozhangwang An optimization which may reduce unnecessary poll for standby tasks. You can merge this pull request into

[GitHub] kafka pull request: MINOR: add KStream merge operator

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/536 MINOR: add KStream merge operator @guozhangwang Added KStreamBuilder.merge(KStream...). You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] kafka pull request: MINOR: do not create a StandbyTask if there is...

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

[GitHub] kafka pull request: KAFKA-2831; Do not use ZKUtils in `ConsumerGro...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/528 --- 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-2831) kafka-consumer-groups requires zookeeper url when using the new-consumer option

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

[jira] [Updated] (KAFKA-2831) kafka-consumer-groups requires zookeeper url when using the new-consumer option

[ https://issues.apache.org/jira/browse/KAFKA-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2831: --- Resolution: Fixed Status: Resolved (was: Patch Available) > kafka-consumer-groups requires zookeeper

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

See Changes: [wangguoz] KAFKA-2811: add standby tasks [wangguoz] MINOR: do not create a StandbyTask if there is no state store in the [junrao] KAFKA-2831; Do not use ZKUtils in `ConsumerGroupCommand` if --

[GitHub] kafka pull request: KAFKA-2809: Improve documentation linking

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/498 --- 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-2809) Improve documentation linking

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

[jira] [Updated] (KAFKA-2809) Improve documentation linking

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

[jira] [Commented] (KAFKA-2500) Make logEndOffset available in the 0.8.3 Consumer

[ https://issues.apache.org/jira/browse/KAFKA-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007477#comment-15007477 ] Will Funnell commented on KAFKA-2500: - [~hachikuji] Thanks for the update and for the

[jira] [Created] (KAFKA-2845) Add 0.9 clients vs 0.8 brokers compatibility test

Geoff Anderson created KAFKA-2845: - Summary: Add 0.9 clients vs 0.8 brokers compatibility test Key: KAFKA-2845 URL: https://issues.apache.org/jira/browse/KAFKA-2845 Project: Kafka Issue Type:

[GitHub] kafka pull request: KAFKA-2845: new client old broker compatibilit...

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/537 KAFKA-2845: new client old broker compatibility You can merge this pull request into a Git repository by running: $ git pull https://github.com/confluentinc/kafka KAFKA-2845-new-client-old-br

[jira] [Updated] (KAFKA-2845) Add 0.9 clients vs 0.8 brokers compatibility test

[ https://issues.apache.org/jira/browse/KAFKA-2845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Geoff Anderson updated KAFKA-2845: -- Reviewer: Ewen Cheslack-Postava > Add 0.9 clients vs 0.8 brokers compatibility test > --

[jira] [Commented] (KAFKA-2845) Add 0.9 clients vs 0.8 brokers compatibility test

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

[jira] [Updated] (KAFKA-2845) Add 0.9 clients vs 0.8 brokers compatibility test

[ https://issues.apache.org/jira/browse/KAFKA-2845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Geoff Anderson updated KAFKA-2845: -- Status: Patch Available (was: Open) > Add 0.9 clients vs 0.8 brokers compatibility test > -

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

See

[jira] [Commented] (KAFKA-2845) Add 0.9 clients vs 0.8 brokers compatibility test

[ https://issues.apache.org/jira/browse/KAFKA-2845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007575#comment-15007575 ] Grant Henke commented on KAFKA-2845: This is a great test to have. I recently tested t

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

See Changes: [junrao] KAFKA-2809; Improve documentation linking -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (Ubuntu ubuntu) in workspace

[jira] [Created] (KAFKA-2846) Add Ducktape test for kafka-consumer-groups

Ashish K Singh created KAFKA-2846: - Summary: Add Ducktape test for kafka-consumer-groups Key: KAFKA-2846 URL: https://issues.apache.org/jira/browse/KAFKA-2846 Project: Kafka Issue Type: Test

Jenkins build is back to normal : kafka_0.9.0_jdk7 #25

See

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

See Changes: [wangguoz] MINOR: do not create a StandbyTask if there is no state store in the [junrao] KAFKA-2831; Do not use ZKUtils in `ConsumerGroupCommand` if [junrao] KAFKA-2809; Improve documentation linking

[jira] [Resolved] (KAFKA-2721) Avoid handling duplicate LeaderAndISR requests

[ https://issues.apache.org/jira/browse/KAFKA-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2721. Resolution: Fixed Fix Version/s: (was: 0.9.0.1) 0.9.0.0 Issue resolved by pull

[GitHub] kafka pull request: KAFKA-2721; Avoid handling duplicate LeaderAnd...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/436 --- 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-2721) Avoid handling duplicate LeaderAndISR requests

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

[jira] [Commented] (KAFKA-2845) Add 0.9 clients vs 0.8 brokers compatibility test

[ https://issues.apache.org/jira/browse/KAFKA-2845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15007673#comment-15007673 ] Geoff Anderson commented on KAFKA-2845: --- [~granthenke] credit to [~nehanarkhede] for

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

See Changes: [junrao] KAFKA-2721; Avoid handling duplicate LeaderAndISR requests -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-2 (docke

Build failed in Jenkins: kafka_0.9.0_jdk7 #26

See Changes: [junrao] KAFKA-2721; Avoid handling duplicate LeaderAndISR requests -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-1 (docker

Re: JIRA contributor list

Hi Konrad, I have added you to the list. Cheers, Guozhang On Sun, Nov 15, 2015 at 9:08 AM, Konrad Kalita wrote: > Hi, > I'm interested in contributing to Kafka, could you add my account > (username: Konrad Kalita, email: konkal...@gmail.com) to contributor list? > -- -- Guozhang

[GitHub] kafka pull request: KAFKA-2820: systest log level

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/538 KAFKA-2820: systest log level This restores control over log level in KafkaService, and adds SASL debug logging when SASL is enabled You can merge this pull request into a Git repository by running

[jira] [Commented] (KAFKA-2820) System tests: log level is no longer propagating from service classes

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

[jira] [Created] (KAFKA-2847) remove principal.builder.class from client configs

Jun Rao created KAFKA-2847: -- Summary: remove principal.builder.class from client configs Key: KAFKA-2847 URL: https://issues.apache.org/jira/browse/KAFKA-2847 Project: Kafka Issue Type: Bug

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

See

Build failed in Jenkins: kafka_0.9.0_jdk7 #27

See Changes: [junrao] trivial doc change for building customized user name -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-1 (docker Ubunt

[jira] [Created] (KAFKA-2848) Use withClientSslSupport/withClientSaslSupport in Kafka Connect

Ewen Cheslack-Postava created KAFKA-2848: Summary: Use withClientSslSupport/withClientSaslSupport in Kafka Connect Key: KAFKA-2848 URL: https://issues.apache.org/jira/browse/KAFKA-2848 Project

[GitHub] kafka pull request: KAFKA-2848: Use client SSL/SASL config utiliti...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/539 KAFKA-2848: Use client SSL/SASL config utilities in Kafka Connect to avoid duplication of configs. You can merge this pull request into a Git repository by running: $ git pull https://github.co

[jira] [Commented] (KAFKA-2848) Use withClientSslSupport/withClientSaslSupport in Kafka Connect

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

[jira] [Updated] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] netcafe updated KAFKA-2843: --- Description: I use simple consumer fetch message from brokers (fetchSize > messageSize)，when consumer got emp

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

See Changes: [junrao] trivial doc change for building customized user name -- [...truncated 2799 lines...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[11] PASSED kafka.log.Broke

[jira] [Assigned] (KAFKA-2847) remove principal.builder.class from client configs

[ https://issues.apache.org/jira/browse/KAFKA-2847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-2847: -- Assignee: Ismael Juma > remove principal.builder.class from client configs > --

[jira] [Commented] (KAFKA-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15008054#comment-15008054 ] Jun Rao commented on KAFKA-2843: Did you check the error code in the response? For example

[jira] [Commented] (KAFKA-2848) Use withClientSslSupport/withClientSaslSupport in Kafka Connect

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

[GitHub] kafka pull request: KAFKA-2848: Use client SSL/SASL config utiliti...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/539 --- 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-2848) Use withClientSslSupport/withClientSaslSupport in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-2848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2848. Resolution: Fixed Fix Version/s: (was: 0.9.1.0) 0.9.0.0 Issue resolved by pull

[GitHub] kafka pull request: Merge pull request #1 from apache/trunk

GitHub user prabcs opened a pull request: https://github.com/apache/kafka/pull/540 Merge pull request #1 from apache/trunk Merging the kafka latest to my fork You can merge this pull request into a Git repository by running: $ git pull https://github.com/prabcs/kafka trunk Alt

[GitHub] kafka pull request: Merge pull request #1 from apache/trunk

Github user prabcs closed the pull request at: https://github.com/apache/kafka/pull/540 --- 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-2843) when consumer got empty messageset, fetchResponse.highWatermark != current_offset?

[ https://issues.apache.org/jira/browse/KAFKA-2843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15008112#comment-15008112 ] netcafe commented on KAFKA-2843: yes, before parse fetchResponse，I had checked response.h

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

See Changes: [junrao] KAFKA-2848; Use client SSL/SASL config utilities in Kafka Connect to -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubunt

Re: [gradle build] The wrapper should be in the repository

Hi, Those instructions simply fell out of date -- you can see in the README in the repository that the first step after checkout is to bootstrap the gradle wrapper. The wrapper is not included due to licensing issues when creating packages from the repository. I've updated the wiki to explain how