[jira] [Commented] (KAFKA-2914) Kafka Connect Source connector for HBase

[ https://issues.apache.org/jira/browse/KAFKA-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15035439#comment-15035439 ] Ewen Cheslack-Postava commented on KAFKA-2914: -- [~nielsbasjes] Agreed that an

[GitHub] kafka pull request: KAFKA-2718: Add logging to investigate intermi...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/613 KAFKA-2718: Add logging to investigate intermittent unit test failures Print port and directories used by zookeeper in unit tests to figure out which may be causing conflict. You can merge thi

[jira] [Commented] (KAFKA-2718) Reuse of temporary directories leading to transient unit test failures

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

[jira] [Reopened] (KAFKA-2718) Reuse of temporary directories leading to transient unit test failures

[ https://issues.apache.org/jira/browse/KAFKA-2718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reopened KAFKA-2718: --- > Reuse of temporary directories leading to transient unit test failures > ---

[jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15035665#comment-15035665 ] The Data Lorax commented on KAFKA-1894: --- I'm running into this issue and struggling

[jira] [Resolved] (KAFKA-2908) Another, possibly different, Gap in Consumption after Restart

[ https://issues.apache.org/jira/browse/KAFKA-2908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Stopford resolved KAFKA-2908. - Resolution: Fixed Was bug in the way the test defines min.insync.replicas as found by [~rsivaram]

[jira] [Issue Comment Deleted] (KAFKA-2908) Another, possibly different, Gap in Consumption after Restart

[ https://issues.apache.org/jira/browse/KAFKA-2908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Stopford updated KAFKA-2908: Comment: was deleted (was: Was bug in the way the test defines min.insync.replicas as found by [~rs

[jira] [Commented] (KAFKA-2909) Example of Gap in Consumption after Restart

[ https://issues.apache.org/jira/browse/KAFKA-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15035688#comment-15035688 ] Ben Stopford commented on KAFKA-2909: - Was bug in the way the test defines min.insync.

[jira] [Reopened] (KAFKA-2908) Another, possibly different, Gap in Consumption after Restart

[ https://issues.apache.org/jira/browse/KAFKA-2908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Stopford reopened KAFKA-2908: - > Another, possibly different, Gap in Consumption after Restart >

[jira] [Resolved] (KAFKA-2909) Example of Gap in Consumption after Restart

[ https://issues.apache.org/jira/browse/KAFKA-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Stopford resolved KAFKA-2909. - Resolution: Fixed > Example of Gap in Consumption after Restart >

[jira] [Updated] (KAFKA-2908) Consumer Sporadically Stops Consuming From Partition After Server Restart

[ https://issues.apache.org/jira/browse/KAFKA-2908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Stopford updated KAFKA-2908: Summary: Consumer Sporadically Stops Consuming From Partition After Server Restart (was: Another, p

[jira] [Commented] (KAFKA-2642) Run replication tests in ducktape with SSL for clients

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

[jira] [Resolved] (KAFKA-2642) Run replication tests in ducktape with SSL for clients

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

[GitHub] kafka pull request: KAFKA-2642: Run replication tests with SSL and...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/563 --- 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-2912) Add error code 4 (InvalidFetchSize) to Errors.java

[ https://issues.apache.org/jira/browse/KAFKA-2912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15035872#comment-15035872 ] jin xing commented on KAFKA-2912: - I believe the validation for fetch size should be done

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

See Changes: [junrao] KAFKA-2642; Run replication tests with SSL and SASL clients -- [...truncated 2833 lines...] kafka.log.LogTest > testTruncateTo PASSED kafka.log.LogTest > testCleanShutdown

[jira] [Work started] (KAFKA-2929) Remove duplicate error mapping functionality

[ https://issues.apache.org/jira/browse/KAFKA-2929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2929 started by Grant Henke. -- > Remove duplicate error mapping functionality >

[jira] [Created] (KAFKA-2929) Remove duplicate error mapping functionality

Grant Henke created KAFKA-2929: -- Summary: Remove duplicate error mapping functionality Key: KAFKA-2929 URL: https://issues.apache.org/jira/browse/KAFKA-2929 Project: Kafka Issue Type: Improvemen

[jira] [Created] (KAFKA-2930) Update references to ZooKeeper in the docs

Flavio Junqueira created KAFKA-2930: --- Summary: Update references to ZooKeeper in the docs Key: KAFKA-2930 URL: https://issues.apache.org/jira/browse/KAFKA-2930 Project: Kafka Issue Type: Im

[GitHub] kafka pull request: Kafka-2310: Add config to prevent broker becom...

GitHub user abiletskyi opened a pull request: https://github.com/apache/kafka/pull/614 Kafka-2310: Add config to prevent broker becoming controller You can merge this pull request into a Git repository by running: $ git pull https://github.com/stealthly/kafka KAFKA-2310-trunk

[GitHub] kafka pull request: KAFKA-2930: Update references to ZooKeeper in ...

GitHub user fpj opened a pull request: https://github.com/apache/kafka/pull/615 KAFKA-2930: Update references to ZooKeeper in the docs. You can merge this pull request into a Git repository by running: $ git pull https://github.com/fpj/kafka KAFKA-2930 Alternatively you can r

[jira] [Commented] (KAFKA-2930) Update references to ZooKeeper in the docs

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

[jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15036256#comment-15036256 ] Guozhang Wang commented on KAFKA-1894: -- [~BigAndy] You can indeed interrupt the poll(

[jira] [Comment Edited] (KAFKA-1894) Avoid long or infinite blocking in the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15036256#comment-15036256 ] Guozhang Wang edited comment on KAFKA-1894 at 12/2/15 5:56 PM: -

[jira] [Comment Edited] (KAFKA-2851) system tests: error copying keytab file

[ https://issues.apache.org/jira/browse/KAFKA-2851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15010231#comment-15010231 ] Anna Povzner edited comment on KAFKA-2851 at 12/2/15 6:16 PM: --

[GitHub] kafka pull request: KAFKA-2851 Using random dir under /temp for lo...

Github user apovzner closed the pull request at: https://github.com/apache/kafka/pull/609 --- 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-2851) system tests: error copying keytab file

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

[jira] [Commented] (KAFKA-2310) Add config to prevent broker becoming controller

[ https://issues.apache.org/jira/browse/KAFKA-2310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15036359#comment-15036359 ] Aditya Auradkar commented on KAFKA-2310: [~abiletskyi] - I see you submitted a pul

[jira] [Created] (KAFKA-2931) Consumer rolling upgrade test case

Jason Gustafson created KAFKA-2931: -- Summary: Consumer rolling upgrade test case Key: KAFKA-2931 URL: https://issues.apache.org/jira/browse/KAFKA-2931 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-2914) Kafka Connect Source connector for HBase

[ https://issues.apache.org/jira/browse/KAFKA-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15036403#comment-15036403 ] James Cheng commented on KAFKA-2914: [~ewencp], do you want to fork/update https://gi

[GitHub] kafka pull request: KAFKA-2851 Using random file names for local k...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/610 --- 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] [Created] (KAFKA-2932) Adjust importance level of Kafka Connect configs

Ewen Cheslack-Postava created KAFKA-2932: Summary: Adjust importance level of Kafka Connect configs Key: KAFKA-2932 URL: https://issues.apache.org/jira/browse/KAFKA-2932 Project: Kafka

[jira] [Commented] (KAFKA-2851) system tests: error copying keytab file

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

[GitHub] kafka pull request: KAFKA-2880: consumer should handle disconnect/...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/581 --- 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-2880) Fetcher.getTopicMetadata NullPointerException when broker cannot be reached

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

[jira] [Resolved] (KAFKA-2880) Fetcher.getTopicMetadata NullPointerException when broker cannot be reached

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

[GitHub] kafka pull request: KAFKA-2929: Remove duplicate error mapping fun...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/616 KAFKA-2929: Remove duplicate error mapping functionality Removes ErrorMapping.scala in core in favor or Errors.java in common. Duplicated exceptions in core are removed as well, to ensure the

[jira] [Commented] (KAFKA-2929) Remove duplicate error mapping functionality

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

[jira] [Updated] (KAFKA-2929) Remove duplicate error mapping functionality

[ https://issues.apache.org/jira/browse/KAFKA-2929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2929: --- Status: Patch Available (was: In Progress) > Remove duplicate error mapping functionality > -

[GitHub] kafka pull request: Minor: ConsoleConsumer - Fix number of process...

GitHub user luafran opened a pull request: https://github.com/apache/kafka/pull/617 Minor: ConsoleConsumer - Fix number of processed messages count kafka-console-consumer.sh is showing an incorrect number of messages processed, counting one more message than the actual number

[jira] [Updated] (KAFKA-2851) system tests: error copying keytab file

[ https://issues.apache.org/jira/browse/KAFKA-2851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-2851: Reviewer: Guozhang Wang (was: Gwen Shapira) > system tests: error copying keytab file > ---

Build failed in Jenkins: kafka_0.9.0_jdk7 #54

See Changes: [wangguoz] KAFKA-2880: consumer should handle disconnect/timeout for metadata -- [...truncated 3800 lines...] kafka.log.LogTest > testParseTopicPartitionNameForMissingTopic PASSED ka

[jira] [Created] (KAFKA-2933) Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment

Guozhang Wang created KAFKA-2933: Summary: Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment Key: KAFKA-2933 URL: https://issues.apache.org/jira/browse/KAFKA-2933 Project:

[jira] [Assigned] (KAFKA-2933) Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment

[ https://issues.apache.org/jira/browse/KAFKA-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2933: -- Assignee: Jason Gustafson > Failure in kafka.api.PlaintextConsumerTest.testMultiConsume

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

See Changes: [wangguoz] KAFKA-2851 Using random file names for local kdc files to avoid [wangguoz] KAFKA-2880: consumer should handle disconnect/timeout for metadata -- [...truncated 6799 lines.

[jira] [Updated] (KAFKA-2851) system tests: error copying keytab file

[ https://issues.apache.org/jira/browse/KAFKA-2851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-2851: Resolution: Fixed Status: Resolved (was: Patch Available) > system tests: error copying key

[jira] [Created] (KAFKA-2934) Offset storage file configuration in Connect standalone mode is not included in StandaloneConfig

Ewen Cheslack-Postava created KAFKA-2934: Summary: Offset storage file configuration in Connect standalone mode is not included in StandaloneConfig Key: KAFKA-2934 URL: https://issues.apache.org/jira/brows

[jira] [Created] (KAFKA-2935) Remove vestigial CLUSTER_CONFIG in WorkerConfig

Ewen Cheslack-Postava created KAFKA-2935: Summary: Remove vestigial CLUSTER_CONFIG in WorkerConfig Key: KAFKA-2935 URL: https://issues.apache.org/jira/browse/KAFKA-2935 Project: Kafka

[GitHub] kafka pull request: KAFKA-2825: Add controller failover to existin...

GitHub user apovzner opened a pull request: https://github.com/apache/kafka/pull/618 KAFKA-2825: Add controller failover to existing replication tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/apovzner/kafka kafka_2825_01

[jira] [Commented] (KAFKA-2825) Add controller failover to existing replication tests

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

[jira] [Commented] (KAFKA-2931) Consumer rolling upgrade test case

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

[GitHub] kafka pull request: KAFKA-2931: add system test for consumer rolli...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/619 KAFKA-2931: add system test for consumer rolling upgrades You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-2931 Alternati

[jira] [Assigned] (KAFKA-1342) Slow controlled shutdowns can result in stale shutdown requests

[ https://issues.apache.org/jira/browse/KAFKA-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman reassigned KAFKA-1342: --- Assignee: Onur Karaman (was: Jiangjie Qin) > Slow controlled shutdowns can result in stale s

Kafka Summit Registration and CFP

Hey Everyone, As you may have heard, Confluent is hosting the first ever Kafka Summit. It'll be in San Francisco on Tuesday, April 26, 2016. We'll be announcing open registration tomorrow, but I wanted to let everyone here know first, and also let you know there is a $50 community discount. To ge

[jira] [Commented] (KAFKA-2934) Offset storage file configuration in Connect standalone mode is not included in StandaloneConfig

[ https://issues.apache.org/jira/browse/KAFKA-2934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15036882#comment-15036882 ] Ewen Cheslack-Postava commented on KAFKA-2934: -- Also found a couple of other

[GitHub] kafka pull request: MINOR: Manually ported changes in 8c3c9548b636...

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/620 MINOR: Manually ported changes in 8c3c9548b636cdf760d2537afe115942d13bc003 Porting manually to 0.9.0 (no cherry-pick due to conflicts) This will allow concurrent system test runs on the sam

[jira] [Updated] (KAFKA-2936) Socket server selector can stuck on one send in tight loop.

[ https://issues.apache.org/jira/browse/KAFKA-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2936: Affects Version/s: 0.9.0.0 > Socket server selector can stuck on one send in tight loop. > -

[jira] [Updated] (KAFKA-2936) Socket server selector can stuck on one send in tight loop.

[ https://issues.apache.org/jira/browse/KAFKA-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2936: Fix Version/s: 0.9.0.1 > Socket server selector can stuck on one send in tight loop. > -

[jira] [Created] (KAFKA-2936) Socket server selector can stuck on one send in tight loop.

Jiangjie Qin created KAFKA-2936: --- Summary: Socket server selector can stuck on one send in tight loop. Key: KAFKA-2936 URL: https://issues.apache.org/jira/browse/KAFKA-2936 Project: Kafka Issu

[jira] [Created] (KAFKA-2937) Topics marked for delete in Zookeeper may become undeletable

Rajini Sivaram created KAFKA-2937: - Summary: Topics marked for delete in Zookeeper may become undeletable Key: KAFKA-2937 URL: https://issues.apache.org/jira/browse/KAFKA-2937 Project: Kafka

[jira] [Updated] (KAFKA-2936) Socket server selector can stuck on one send in tight loop.

[ https://issues.apache.org/jira/browse/KAFKA-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2936: Component/s: network > Socket server selector can stuck on one send in tight loop. > ---

[jira] [Updated] (KAFKA-2936) Socket server selector can stuck on one send in tight loop.

[ https://issues.apache.org/jira/browse/KAFKA-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-2936: Assignee: Onur Karaman > Socket server selector can stuck on one send in tight loop. > -

[jira] [Created] (KAFKA-2938) Socket server may throw IllegalStateException

Jiangjie Qin created KAFKA-2938: --- Summary: Socket server may throw IllegalStateException Key: KAFKA-2938 URL: https://issues.apache.org/jira/browse/KAFKA-2938 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

Guozhang Wang created KAFKA-2939: Summary: Make AbstractConfig.logUnused() tunable for clients Key: KAFKA-2939 URL: https://issues.apache.org/jira/browse/KAFKA-2939 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-2937) Topics marked for delete in Zookeeper may become undeletable

[ https://issues.apache.org/jira/browse/KAFKA-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat reassigned KAFKA-2937: -- Assignee: Mayuresh Gharat > Topics marked for delete in Zookeeper may become undeletabl

[jira] [Commented] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15036977#comment-15036977 ] Jay Kreps commented on KAFKA-2939: -- That was the whole point of the original implementati

[jira] [Created] (KAFKA-2940) Make available to use any Java options at startup scripts

Sasaki Toru created KAFKA-2940: -- Summary: Make available to use any Java options at startup scripts Key: KAFKA-2940 URL: https://issues.apache.org/jira/browse/KAFKA-2940 Project: Kafka Issue Typ

[GitHub] kafka pull request: KAFKA-2804: manage changelog topics through ZK...

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

[GitHub] kafka pull request: KAFKA-2804: manage changelog topics through ZK...

GitHub user guozhangwang reopened a pull request: https://github.com/apache/kafka/pull/579 KAFKA-2804: manage changelog topics through ZK in PartitionAssignor You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K28

[jira] [Commented] (KAFKA-2804) Create / Update changelog topics upon state store initialization

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

[jira] [Commented] (KAFKA-2804) Create / Update changelog topics upon state store initialization

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

[GitHub] kafka pull request: Kafka 2902 streaming config use get base consu...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/596 --- 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-2902) StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs

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

[GitHub] kafka pull request: KAFKA-2940: Make available to use any Java opt...

GitHub user sasakitoa opened a pull request: https://github.com/apache/kafka/pull/621 KAFKA-2940: Make available to use any Java options at startup scripts We cannot specify any Java options (e.g. option for remote debugging) at startup scrips such as kafka-server-start.sh . Thi

[jira] [Commented] (KAFKA-2940) Make available to use any Java options at startup scripts

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

[jira] [Commented] (KAFKA-2938) Socket server may throw IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-2938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15037137#comment-15037137 ] Jun Rao commented on KAFKA-2938: [~becket_qin], can this actually happen? In SocketServer,

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

See Changes: [wangguoz] KAFKA-2902: streaming config use get base consumer configs. -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-2 (do

[jira] [Commented] (KAFKA-2308) New producer + Snappy face un-compression errors after broker restart

[ https://issues.apache.org/jira/browse/KAFKA-2308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15037210#comment-15037210 ] ASF GitHub Bot commented on KAFKA-2308: --- Github user darionyaphet commented on the p

[GitHub] kafka pull request: KAFKA-2924: support offsets topic in DumpLogSe...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/622 KAFKA-2924: support offsets topic in DumpLogSegments You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-2924 Alternatively

[jira] [Commented] (KAFKA-2924) Add offsets/group metadata decoder so that DumpLogSegments can be used with the offsets topic

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

[jira] [Commented] (KAFKA-2938) Socket server may throw IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-2938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15037259#comment-15037259 ] Jiangjie Qin commented on KAFKA-2938: - [~junrao]You are right. We actually mute the ch

[jira] [Resolved] (KAFKA-2938) Socket server may throw IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-2938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved KAFKA-2938. - Resolution: Not A Problem > Socket server may throw IllegalStateException > --

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

See Changes: [wangguoz] KAFKA-2902: streaming config use get base consumer configs. -- [...truncated 2808 lines...] kafka.log.LogTest > testTimeBasedLogRollJitter PASSED kafka.log.LogTest > test

[jira] [Created] (KAFKA-2941) Docs for key/value converter in Kafka connect are unclear

Ewen Cheslack-Postava created KAFKA-2941: Summary: Docs for key/value converter in Kafka connect are unclear Key: KAFKA-2941 URL: https://issues.apache.org/jira/browse/KAFKA-2941 Project: Kafka

[GitHub] kafka pull request: KAFKA-2942: inadvertent auto-commit when pre-f...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/623 KAFKA-2942: inadvertent auto-commit when pre-fetching can cause message loss You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KA

[jira] [Commented] (KAFKA-2942) Inadvertent auto-commit when pre-fetching can cause message loss

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

[jira] [Created] (KAFKA-2942) Inadvertent auto-commit when pre-fetching can cause message loss

Jason Gustafson created KAFKA-2942: -- Summary: Inadvertent auto-commit when pre-fetching can cause message loss Key: KAFKA-2942 URL: https://issues.apache.org/jira/browse/KAFKA-2942 Project: Kafka