[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

[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] [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

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] [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 > --

[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] [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

[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-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

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-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,

[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

[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] [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 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] [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

[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

[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] [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

[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] [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] [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] [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] [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-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: Fix Version/s: 0.9.0.1 > 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: Affects Version/s: 0.9.0.0 > Socket server selector can stuck on one send in tight loop. > -

[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] [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

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] [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

[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] [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:

[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] [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

[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] [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

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] [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

[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:

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] [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 > ---

[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-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 > -

[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

[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] [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

[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

[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-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

[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

[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] [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

[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-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] [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

[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] [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: --

[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] [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] [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:

[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

[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

[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

[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] [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 >

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] [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

[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] [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

[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] [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-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] [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] [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] [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] [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-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

[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-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