[jira] [Commented] (KAFKA-1801) Remove non-functional variable definition in log4j.properties

[ https://issues.apache.org/jira/browse/KAFKA-1801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129946#comment-15129946 ] Lee Hanxue commented on KAFKA-1801: --- Removing the {{kafka.logs.dir}} variable definition

[jira] [Commented] (KAFKA-3170) Default value of fetch_min_bytes in new consumer is 1024 while doc says it is 1

[ https://issues.apache.org/jira/browse/KAFKA-3170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129795#comment-15129795 ] Guozhang Wang commented on KAFKA-3170: -- Yes, thanks for reminding :) > Default value

[jira] [Updated] (KAFKA-3170) Default value of fetch_min_bytes in new consumer is 1024 while doc says it is 1

[ https://issues.apache.org/jira/browse/KAFKA-3170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3170: - Fix Version/s: 0.9.0.1 > Default value of fetch_min_bytes in new consumer is 1024 while doc says i

[jira] [Updated] (KAFKA-3170) Default value of fetch_min_bytes in new consumer is 1024 while doc says it is 1

[ https://issues.apache.org/jira/browse/KAFKA-3170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3170: - Resolution: Fixed Status: Resolved (was: Patch Available) > Default value of fetch_min_by

[jira] [Commented] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin

[ https://issues.apache.org/jira/browse/KAFKA-2875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129791#comment-15129791 ] ASF GitHub Bot commented on KAFKA-2875: --- GitHub user ZoneMayor reopened a pull reque

[jira] [Commented] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin

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

[GitHub] kafka pull request: KAFKA-2875: remove slf4j multi binding warning...

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

[GitHub] kafka pull request: KAFKA-2875: remove slf4j multi binding warning...

GitHub user ZoneMayor reopened a pull request: https://github.com/apache/kafka/pull/693 KAFKA-2875: remove slf4j multi binding warnings when running form source distribution hi @ijuma I reopened this pr again (sorry for my inexperience using github); I think I did much deduplic

RE: [jira] [Commented] (KAFKA-2143) Replicas get ahead of leader and fail

i meet the same issues,the error log, Error when processing fetch request for partition [To_S3_comm_V0_10,2] offset 456234794 from follower with correlation id 254117341. Possible cause: Request for offset 456234794 but we only have log segmen ts in the range 432322850 to 456234793. (kafka.server.

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

See Changes: [me] KAFKA-3195; Transient test failure in OffsetCheckpointTest.testReadWrite -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (

[jira] [Commented] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin

[ https://issues.apache.org/jira/browse/KAFKA-2875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129723#comment-15129723 ] ASF GitHub Bot commented on KAFKA-2875: --- GitHub user ZoneMayor reopened a pull reque

[GitHub] kafka pull request: KAFKA-2875: remove slf4j multi binding warning...

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

[jira] [Commented] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin

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

[GitHub] kafka pull request: KAFKA-2875: remove slf4j multi binding warning...

GitHub user ZoneMayor reopened a pull request: https://github.com/apache/kafka/pull/693 KAFKA-2875: remove slf4j multi binding warnings when running form source distribution hi @ijuma I reopened this pr again (sorry for my inexperience using github); I think I did much deduplic

[jira] [Commented] (KAFKA-3170) Default value of fetch_min_bytes in new consumer is 1024 while doc says it is 1

[ https://issues.apache.org/jira/browse/KAFKA-3170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129719#comment-15129719 ] Grant Henke commented on KAFKA-3170: [~guozhang] Should this be marked resolved for 0.

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

See Changes: [me] MINOR: Increment ducktape dependency -- [...truncated 6631 lines...] org.apache.kafka.connect.runtime.rest.resources.ConnectorsResourceTest > testPutConnectorTaskConfigs PASSED

[jira] [Assigned] (KAFKA-3044) Consumer.poll doesnot return messages when poll interval is less

[ https://issues.apache.org/jira/browse/KAFKA-3044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Praveen Devarao reassigned KAFKA-3044: -- Assignee: Praveen Devarao (was: Jason Gustafson) > Consumer.poll doesnot return messag

[jira] [Updated] (KAFKA-3189) Kafka server returns UnknownServerException for inherited exceptions

[ https://issues.apache.org/jira/browse/KAFKA-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3189: --- Status: Patch Available (was: Open) > Kafka server returns UnknownServerException for inherited excep

[jira] [Commented] (KAFKA-3189) Kafka server returns UnknownServerException for inherited exceptions

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

[GitHub] kafka pull request: KAFKA-3189: Kafka server returns UnknownServer...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/856 KAFKA-3189: Kafka server returns UnknownServerException for inherited… … exceptions You can merge this pull request into a Git repository by running: $ git pull https://github.com/granthe

[jira] [Commented] (KAFKA-3189) Kafka server returns UnknownServerException for inherited exceptions

[ https://issues.apache.org/jira/browse/KAFKA-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129685#comment-15129685 ] Grant Henke commented on KAFKA-3189: [~becket_qin] [~ijuma] I updated the jira descrip

[jira] [Updated] (KAFKA-3189) Kafka server returns UnknownServerException for inherited exceptions

[ https://issues.apache.org/jira/browse/KAFKA-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3189: --- Description: This issue was introduced in KAFKA-2929. The problem is that we are using o.a.k.common.p

[jira] [Updated] (KAFKA-3189) Kafka server returns UnknownServerException for inherited exceptions

[ https://issues.apache.org/jira/browse/KAFKA-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3189: --- Summary: Kafka server returns UnknownServerException for inherited exceptions (was: Kafka server alwa

[jira] [Updated] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

[ https://issues.apache.org/jira/browse/KAFKA-3195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3195: - Resolution: Fixed Fix Version/s: 0.9.1.0 Status: Resolved (was:

[jira] [Commented] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

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

[jira] [Commented] (KAFKA-3174) Re-evaluate the CRC32 class performance.

[ https://issues.apache.org/jira/browse/KAFKA-3174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129644#comment-15129644 ] Jiangjie Qin commented on KAFKA-3174: - [~ijuma] Thanks for the clarification. Yes, I a

[GitHub] kafka pull request: KAFKA-3195; Transient test failure in OffsetCh...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/855 --- 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] [Assigned] (KAFKA-3197) Producer can send message out of order even when in flight request is set to 1.

[ https://issues.apache.org/jira/browse/KAFKA-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-3197: --- Assignee: Jiangjie Qin (was: Jun Rao) > Producer can send message out of order even when in

[DISCUSS] KIP-46: Self Healing

Hey everyone, I just created a kip to discuss automated replica reassignment when we lose a broker in the cluster. https://cwiki.apache.org/confluence/display/KAFKA/KIP-46%3A+Self+Healing+Kafka Any feedback is welcome. Thanks, Aditya

[jira] [Created] (KAFKA-3197) Producer can send message out of order even when in flight request is set to 1.

Jiangjie Qin created KAFKA-3197: --- Summary: Producer can send message out of order even when in flight request is set to 1. Key: KAFKA-3197 URL: https://issues.apache.org/jira/browse/KAFKA-3197 Project:

[GitHub] kafka pull request: MINOR: Increment ducktape dependency

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/852 --- 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-3157) Mirror maker doesn't commit offset with new consumer when there is no more messages

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

[jira] [Commented] (KAFKA-3157) Mirror maker doesn't commit offset with new consumer when there is no more messages

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

[GitHub] kafka pull request: KAFKA-3157 - Mirror maker doesn't commit offse...

GitHub user xiaotao183 reopened a pull request: https://github.com/apache/kafka/pull/821 KAFKA-3157 - Mirror maker doesn't commit offset Mirror maker doesn't commit offset with new consumer enabled when data volume is low. This is caused by infinite loop in ```receive()``` which wou

[GitHub] kafka pull request: KAFKA-3157 - Mirror maker doesn't commit offse...

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

[jira] [Updated] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

[ https://issues.apache.org/jira/browse/KAFKA-3195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3195: --- Reviewer: Guozhang Wang Status: Patch Available (was: Open) > Transient test failure in OffsetC

[GitHub] kafka pull request: KAFKA-3195; Transient test failure in OffsetCh...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/855 KAFKA-3195; Transient test failure in OffsetCheckpointTest.testReadWrite You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka kafka-3195-of

[jira] [Commented] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

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

[jira] [Commented] (KAFKA-3178) Expose a method in AdminUtils to manually truncate a specific partition to a particular offset

[ https://issues.apache.org/jira/browse/KAFKA-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129547#comment-15129547 ] Vahid Hashemian commented on KAFKA-3178: [~wwarshaw] Thanks for letting me know. I

[jira] [Commented] (KAFKA-3178) Expose a method in AdminUtils to manually truncate a specific partition to a particular offset

[ https://issues.apache.org/jira/browse/KAFKA-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129513#comment-15129513 ] Bill Warshaw commented on KAFKA-3178: - [~vahid] fyi this ticket may end up closing; we

[jira] [Updated] (KAFKA-3162) KIP-42: Add Producer and Consumer Interceptors

[ https://issues.apache.org/jira/browse/KAFKA-3162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-3162: Status: Patch Available (was: In Progress) > KIP-42: Add Producer and Consumer Interceptors > -

[jira] [Commented] (KAFKA-3129) Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129499#comment-15129499 ] Jason Gustafson commented on KAFKA-3129: I haven't been able to reproduce this. It

[jira] [Commented] (KAFKA-3162) KIP-42: Add Producer and Consumer Interceptors

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

[GitHub] kafka pull request: KAFKA-3162: Added producer and consumer interc...

GitHub user apovzner opened a pull request: https://github.com/apache/kafka/pull/854 KAFKA-3162: Added producer and consumer interceptors This is the most of the KIP-42: Producer and consumer interceptor. (Except exposing CRC and record sizes to the interceptor, which is coming as a

[jira] [Updated] (KAFKA-3162) KIP-42: Add Producer and Consumer Interceptors

[ https://issues.apache.org/jira/browse/KAFKA-3162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-3162: Issue Type: Improvement (was: Bug) > KIP-42: Add Producer and Consumer Interceptors > -

[jira] [Created] (KAFKA-3196) KIP-42 (part 2): add record size and CRC to RecordMetadata and ConsumerRecords

Anna Povzner created KAFKA-3196: --- Summary: KIP-42 (part 2): add record size and CRC to RecordMetadata and ConsumerRecords Key: KAFKA-3196 URL: https://issues.apache.org/jira/browse/KAFKA-3196 Project: K

[jira] [Updated] (KAFKA-3162) KIP-42: Add Producer and Consumer Interceptors

[ https://issues.apache.org/jira/browse/KAFKA-3162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-3162: Description: This JIRA is for main part of KIP-42 implementation, which includes: 1. Add ProducerIn

[GitHub] kafka pull request: MINOR: some more Javadocs

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/853 MINOR: some more Javadocs You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KJavaDoc Alternatively you can review and appl

[jira] [Commented] (KAFKA-3129) Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129449#comment-15129449 ] Vahid Hashemian commented on KAFKA-3129: As I mentioned, in the input file I have

[jira] [Commented] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

[ https://issues.apache.org/jira/browse/KAFKA-3195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129438#comment-15129438 ] Ismael Juma commented on KAFKA-3195: Sure. > Transient test failure in OffsetCheckpoi

[jira] [Assigned] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

[ https://issues.apache.org/jira/browse/KAFKA-3195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-3195: -- Assignee: Ismael Juma (was: Guozhang Wang) > Transient test failure in OffsetCheckpointTest.te

[jira] [Commented] (KAFKA-3129) Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129427#comment-15129427 ] Jason Gustafson commented on KAFKA-3129: Are the missing messages always the last

[jira] [Commented] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

[ https://issues.apache.org/jira/browse/KAFKA-3195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129426#comment-15129426 ] Guozhang Wang commented on KAFKA-3195: -- Thanks [~ewencp]. [~ijuma] Do you want to pro

[jira] [Commented] (KAFKA-3129) Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129419#comment-15129419 ] Vahid Hashemian commented on KAFKA-3129: Thanks [~hachikuji] for the suggestion. I

[jira] [Assigned] (KAFKA-3178) Expose a method in AdminUtils to manually truncate a specific partition to a particular offset

[ https://issues.apache.org/jira/browse/KAFKA-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-3178: -- Assignee: Vahid Hashemian > Expose a method in AdminUtils to manually truncate a specif

[GitHub] kafka pull request: MINOR: Increment ducktape dependency

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/852 MINOR: Increment ducktape dependency Pin kafka system tests to a newer version of ducktape. Ran in branch builder; only one preexisting (transient) failure: http://confluent-kafka-branc

[jira] [Commented] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

[ https://issues.apache.org/jira/browse/KAFKA-3195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129387#comment-15129387 ] Ismael Juma commented on KAFKA-3195: There is: File f = new File("/tmp/kafka-streams/

[jira] [Commented] (KAFKA-3129) Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129385#comment-15129385 ] Jason Gustafson commented on KAFKA-3129: Ah, my mistake. It actually is being clos

[jira] [Commented] (KAFKA-3129) Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129382#comment-15129382 ] Jason Gustafson commented on KAFKA-3129: [~vahid] Are you using sync or async mode

[jira] [Updated] (KAFKA-3174) Re-evaluate the CRC32 class performance.

[ https://issues.apache.org/jira/browse/KAFKA-3174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3174: --- Fix Version/s: (was: 0.9.0.1) 0.9.1.0 > Re-evaluate the CRC32 class performance

[jira] [Created] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

Ewen Cheslack-Postava created KAFKA-3195: Summary: Transient test failure in OffsetCheckpointTest.testReadWrite Key: KAFKA-3195 URL: https://issues.apache.org/jira/browse/KAFKA-3195 Project: K

[jira] [Commented] (KAFKA-3177) Kafka consumer can hang when position() is called on a non-existing partition.

[ https://issues.apache.org/jira/browse/KAFKA-3177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129355#comment-15129355 ] Jason Gustafson commented on KAFKA-3177: [~guozhang] I think it's useful to separa

[GitHub] kafka pull request: 0.9.0

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

[jira] [Commented] (KAFKA-1545) java.net.InetAddress.getLocalHost in KafkaHealthcheck.register may fail on some irregular hostnames

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

[GitHub] kafka pull request: KAFKA-1545: KafkaHealthcheck.register failure

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

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

[jira] [Commented] (KAFKA-1695) Authenticate connection to Zookeeper

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

[jira] [Commented] (KAFKA-2356) Support retrieving partitions of ConsumerRecords

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

[GitHub] kafka pull request: MINOR: MockClient's disconnect() method has tw...

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

[jira] [Commented] (KAFKA-1369) snappy version update 1.1.x

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

[GitHub] kafka pull request: KAFKA-1695: Adding zookeeper authentication. Z...

Github user stumped2 closed the pull request at: https://github.com/apache/kafka/pull/93 --- 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-1344) Kafka-console-producer.sh support snappy compression

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

[GitHub] kafka pull request: KAFKA-2356 Added support for retrieving partit...

Github user stumped2 closed the pull request at: https://github.com/apache/kafka/pull/95 --- 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-1834) No Response when handle LeaderAndIsrRequest some case

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

[GitHub] kafka pull request: KAFKA-1369 snappy-1.1.x update (RHEL4,5,6)

Github user stumped2 closed the pull request at: https://github.com/apache/kafka/pull/30 --- 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: KAFKA-1834: No Response when handle LeaderAndI...

Github user stumped2 closed the pull request at: https://github.com/apache/kafka/pull/40 --- 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: [KAFKA-1344] - Added compression codec option ...

Github user stumped2 closed the pull request at: https://github.com/apache/kafka/pull/20 --- 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: Switch to using scala 2.9.2

Github user stumped2 closed the pull request at: https://github.com/apache/kafka/pull/1 --- 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-826) Make Kafka 0.8 depend on metrics 2.2.0 instead of 3.x

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

[GitHub] kafka pull request: zkclient and scalatest library updates

Github user stumped2 closed the pull request at: https://github.com/apache/kafka/pull/3 --- 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-3159) Kafka consumer 0.9.0.0 client poll is very CPU intensive under certain conditions

[ https://issues.apache.org/jira/browse/KAFKA-3159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129287#comment-15129287 ] Jason Gustafson commented on KAFKA-3159: [~ra...@signalfx.com] I think we'll proba

[jira] [Updated] (KAFKA-3194) Validate security.inter.broker.protocol against the advertised.listeners protocols

[ https://issues.apache.org/jira/browse/KAFKA-3194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3194: --- Status: Patch Available (was: Open) > Validate security.inter.broker.protocol against the advertised.

[jira] [Commented] (KAFKA-3194) Validate security.inter.broker.protocol against the advertised.listeners protocols

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

[GitHub] kafka pull request: KAFKA-3194: Validate security.inter.broker.pro...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/851 KAFKA-3194: Validate security.inter.broker.protocol against the adver… …tised.listeners protocols You can merge this pull request into a Git repository by running: $ git pull https://gith

[jira] [Updated] (KAFKA-3121) KStream DSL API Improvement

[ https://issues.apache.org/jira/browse/KAFKA-3121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3121: - Description: >From some collected feedbacks, here is a list of potential improvements that >we wa

[jira] [Created] (KAFKA-3194) Validate security.inter.broker.protocol against the advertised.listeners protocols

Grant Henke created KAFKA-3194: -- Summary: Validate security.inter.broker.protocol against the advertised.listeners protocols Key: KAFKA-3194 URL: https://issues.apache.org/jira/browse/KAFKA-3194 Project:

[jira] [Commented] (KAFKA-3188) Add integration test for KIP-31 and KIP-32

[ https://issues.apache.org/jira/browse/KAFKA-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129105#comment-15129105 ] Anna Povzner commented on KAFKA-3188: - [~becket_qin] Do you mind making separate JIRAs

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

See

[jira] [Updated] (KAFKA-3129) Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-3129: --- Summary: Console Producer/Consumer Issue (was: Potential Console Producer/Consumer Issue) >

[jira] [Comment Edited] (KAFKA-3129) Potential Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129021#comment-15129021 ] Vahid Hashemian edited comment on KAFKA-3129 at 2/2/16 9:00 PM:

[jira] [Commented] (KAFKA-3129) Potential Console Producer/Consumer Issue

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129021#comment-15129021 ] Vahid Hashemian commented on KAFKA-3129: Further evidence that this is a producer

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

See Changes: [me] KAFKA-3121: Refactor KStream Aggregate to be Lambda-able. -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (docker Ubuntu u

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

See Changes: [wangguoz] MINOR: some javadocs for kstream public api -- [...truncated 6689 lines...] org.apache.kafka.connect.runtime.rest.resources.ConnectorsResourceTest > testGetConnectorTaskC

[jira] [Resolved] (KAFKA-3121) KStream DSL API Improvement

[ https://issues.apache.org/jira/browse/KAFKA-3121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3121. -- Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull request 8

[jira] [Commented] (KAFKA-3121) KStream DSL API Improvement

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

[GitHub] kafka pull request: KAFKA-3121: Refactor KStream Aggregate to be L...

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

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

See

[jira] [Commented] (KAFKA-3055) JsonConverter mangles schema during serialization (fromConnectData)

[ https://issues.apache.org/jira/browse/KAFKA-3055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128891#comment-15128891 ] Saravanan Tirugnanum commented on KAFKA-3055: - Hi Kishore I am facing this sa

[jira] [Work started] (KAFKA-3191) Improve offset committing JavaDoc in KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-3191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3191 started by Adam Kunicki. --- > Improve offset committing JavaDoc in KafkaConsumer >

[jira] [Commented] (KAFKA-3191) Improve offset committing JavaDoc in KafkaConsumer

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

  1   2   >