[jira] [Commented] (KAFKA-4160) Consumer onPartitionsRevoked should not be invoked while holding the coordinator lock

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

[GitHub] kafka pull request #1855: KAFKA-4160: Ensure rebalance listener not called w...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1855 --- 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] [Resolved] (KAFKA-4160) Consumer onPartitionsRevoked should not be invoked while holding the coordinator lock

[ https://issues.apache.org/jira/browse/KAFKA-4160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4160. -- Resolution: Fixed Issue resolved by pull request 1855

[jira] [Updated] (KAFKA-4174) Delete a Config that does not exist in ConsumerConfig

[ https://issues.apache.org/jira/browse/KAFKA-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shunichi ishii updated KAFKA-4174: -- Description: $ ./bin/kafka-run-class.sh org.apache.kafka.streams.examples.pipe.PipeDemo

[jira] [Created] (KAFKA-4174) Delete a Config that does not exist in ConsumerConfig

shunichi ishii created KAFKA-4174: - Summary: Delete a Config that does not exist in ConsumerConfig Key: KAFKA-4174 URL: https://issues.apache.org/jira/browse/KAFKA-4174 Project: Kafka Issue

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

See Changes: [jason] KAFKA-4172; Ensure fetch responses contain the requested partitions -- [...truncated 5268 lines...] kafka.api.PlaintextProducerSendTest > testSendToPartition STARTED

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

See

[jira] [Commented] (KAFKA-3590) KafkaConsumer fails with "Messages are rejected since there are fewer in-sync replicas than required." when polling

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

[GitHub] kafka pull request #1859: KAFKA-3590: Handle not-enough-replicas errors when...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1859 KAFKA-3590: Handle not-enough-replicas errors when writing to offsets topic You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[jira] [Commented] (KAFKA-4172) Fix masked test error in KafkaConsumerTest.testSubscriptionChangesWithAutoCommitEnabled

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

[GitHub] kafka pull request #1857: KAFKA-4172: Ensure fetch responses contain the req...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1857 --- 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] [Resolved] (KAFKA-4172) Fix masked test error in KafkaConsumerTest.testSubscriptionChangesWithAutoCommitEnabled

[ https://issues.apache.org/jira/browse/KAFKA-4172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4172. Resolution: Fixed Issue resolved by pull request 1857

[GitHub] kafka pull request #1858: HOTFIX: set sourceNodes to null for selectKey

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/1858 HOTFIX: set sourceNodes to null for selectKey To indicate its source topic is no longer guaranteed to be partitioned on key. You can merge this pull request into a Git repository by running:

[jira] [Created] (KAFKA-4173) SchemaProjector should successfully project when source schema field is missing and target schema field is optional

Shikhar Bhushan created KAFKA-4173: -- Summary: SchemaProjector should successfully project when source schema field is missing and target schema field is optional Key: KAFKA-4173 URL:

[jira] [Commented] (KAFKA-4172) Fix masked test error in KafkaConsumerTest.testSubscriptionChangesWithAutoCommitEnabled

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

[GitHub] kafka pull request #1857: KAFKA-4172: Ensure fetches responses contain the r...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1857 KAFKA-4172: Ensure fetches responses contain the requested partitions You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[jira] [Created] (KAFKA-4172) Fix masked test error in KafkaConsumerTest.testSubscriptionChangesWithAutoCommitEnabled

Jason Gustafson created KAFKA-4172: -- Summary: Fix masked test error in KafkaConsumerTest.testSubscriptionChangesWithAutoCommitEnabled Key: KAFKA-4172 URL: https://issues.apache.org/jira/browse/KAFKA-4172

[jira] [Work started] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4114 started by Bill Bejeck. -- > Allow for different "auto.offset.reset" strategies for different input streams >

[jira] [Commented] (KAFKA-4153) Incorrect KStream-KStream join behavior with asymmetric time window

[ https://issues.apache.org/jira/browse/KAFKA-4153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15491553#comment-15491553 ] Elias Levy commented on KAFKA-4153: --- I've updated the PR to reverse the before & after semantics as

[jira] [Commented] (KAFKA-4171) Kafka-connect prints outs keystone and truststore password in log2

[ https://issues.apache.org/jira/browse/KAFKA-4171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15491532#comment-15491532 ] Ewen Cheslack-Postava commented on KAFKA-4171: -- Yeah, that's almost definitely what's

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

See Changes: [me] KAFKA-4162: Fixed typo "rebalance" -- [...truncated 4880 lines...] kafka.api.SaslPlainPlaintextConsumerTest > testCoordinatorFailover PASSED

Build failed in Jenkins: kafka-0.10.0-jdk7 #199

See Changes: [me] KAFKA-4162: Fixed typo "rebalance" -- [...truncated 5756 lines...] org.apache.kafka.streams.kstream.internals.KTableMapValuesTest > testValueGetter PASSED

[jira] [Commented] (KAFKA-4074) Deleting a topic can make it unavailable even if delete.topic.enable is false

[ https://issues.apache.org/jira/browse/KAFKA-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15491390#comment-15491390 ] Mayuresh Gharat commented on KAFKA-4074: [~omkreddy] merging your PR with that in

[jira] [Commented] (KAFKA-4153) Incorrect KStream-KStream join behavior with asymmetric time window

[ https://issues.apache.org/jira/browse/KAFKA-4153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15491329#comment-15491329 ] Guozhang Wang commented on KAFKA-4153: -- According to the stated Java doc string, {{JoinWindows}}

[GitHub] kafka pull request #1856: Allow underscores in hostname

GitHub user rnpridgeon opened a pull request: https://github.com/apache/kafka/pull/1856 Allow underscores in hostname Technically this does not strictly adhere to RFC-952 however it is valid for domain names, urls and uris so we should loosen the requirements a tad. You can merge

[jira] [Commented] (KAFKA-4161) Allow connectors to request flush via the context

[ https://issues.apache.org/jira/browse/KAFKA-4161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15491296#comment-15491296 ] Shikhar Bhushan commented on KAFKA-4161: bq. Probably worth clarifying whether we're really

[jira] [Reopened] (KAFKA-4058) Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset

[ https://issues.apache.org/jira/browse/KAFKA-4058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-4058: -- Re-open this issue since this transient error is still observable. Sharing [~enothereska] 's stack

[jira] [Updated] (KAFKA-3719) Pattern regex org.apache.kafka.common.utils.Utils.HOST_PORT_PATTERN is too narrow

[ https://issues.apache.org/jira/browse/KAFKA-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan P updated KAFKA-3719: -- Assignee: Ryan P > Pattern regex org.apache.kafka.common.utils.Utils.HOST_PORT_PATTERN is too > narrow >

[jira] [Reopened] (KAFKA-3719) Pattern regex org.apache.kafka.common.utils.Utils.HOST_PORT_PATTERN is too narrow

[ https://issues.apache.org/jira/browse/KAFKA-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan P reopened KAFKA-3719: --- I would like to re-open this topic for discussion. While [~gwenshap] is correct, underscores are not valid

[jira] [Commented] (KAFKA-4171) Kafka-connect prints outs keystone and truststore password in log2

[ https://issues.apache.org/jira/browse/KAFKA-4171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15491164#comment-15491164 ] Chris Riccomini commented on KAFKA-4171: Wondering if KC is just putting configuration from

[jira] [Created] (KAFKA-4171) Kafka-connect prints outs keystone and truststore password in log2

Akshath Patkar created KAFKA-4171: - Summary: Kafka-connect prints outs keystone and truststore password in log2 Key: KAFKA-4171 URL: https://issues.apache.org/jira/browse/KAFKA-4171 Project: Kafka

[jira] [Commented] (KAFKA-4160) Consumer onPartitionsRevoked should not be invoked while holding the coordinator lock

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

[GitHub] kafka pull request #1855: KAFKA-4160: Ensure rebalance listener not called w...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1855 KAFKA-4160: Ensure rebalance listener not called with coordinator lock You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[jira] [Commented] (KAFKA-4108) Improve DumpLogSegments offsets-decoder output format

[ https://issues.apache.org/jira/browse/KAFKA-4108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15491082#comment-15491082 ] Vahid Hashemian commented on KAFKA-4108: [~hachikuji] Would changing the output format from {code}

[jira] [Resolved] (KAFKA-4162) Typo in Kafka Connect document

[ https://issues.apache.org/jira/browse/KAFKA-4162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4162. -- Resolution: Fixed Fix Version/s: 0.10.1.0 0.10.0.2

[GitHub] kafka pull request #1853: KAFKA-4162: Fixed typo "rebalance"

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1853 --- 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-4162) Typo in Kafka Connect document

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

Re: [VOTE] KIP-79 - ListOffsetRequest v1 and search by timestamp methods in new consumer.

+1 On Tue, Sep 13, 2016 at 11:08 PM, Jason Gustafson wrote: > +1 and thanks for the great proposal! > > On Fri, Sep 9, 2016 at 4:38 PM, Becket Qin wrote: > > > Hi all, > > > > I'd like to start the voting for KIP-79 > > > > In short we propose to : > >

[GitHub] kafka pull request #1854: MINOR: Give a name to the coordinator heartbeat th...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1854 --- 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 #1854: MINOR: Give a name to the coordinator heartbeat th...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/1854 MINOR: Give a name to the coordinator heartbeat thread Followed the same naming pattern as the producer sender thread. You can merge this pull request into a Git repository by running: $ git

[jira] [Work started] (KAFKA-4167) Add cache metrics

[ https://issues.apache.org/jira/browse/KAFKA-4167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4167 started by Eno Thereska. --- > Add cache metrics > - > > Key: KAFKA-4167 >

[jira] [Commented] (KAFKA-4162) Typo in Kafka Connect document

[ https://issues.apache.org/jira/browse/KAFKA-4162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15490664#comment-15490664 ] David Chen commented on KAFKA-4162: --- PR submitted: https://github.com/apache/kafka/pull/1853 > Typo in

[jira] [Created] (KAFKA-4170) required() method not available in joptsimple.OptionSpec

Martin Gainty created KAFKA-4170: Summary: required() method not available in joptsimple.OptionSpec Key: KAFKA-4170 URL: https://issues.apache.org/jira/browse/KAFKA-4170 Project: Kafka

[jira] [Assigned] (KAFKA-4167) Add cache metrics

[ https://issues.apache.org/jira/browse/KAFKA-4167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reassigned KAFKA-4167: --- Assignee: Eno Thereska > Add cache metrics > - > > Key:

[jira] [Commented] (KAFKA-4169) Calculation of message size is too conservative for compressed messages

[ https://issues.apache.org/jira/browse/KAFKA-4169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15490387#comment-15490387 ] Dustin Cote commented on KAFKA-4169: Ah, good point. The user reporting this issue suggested pushing

[jira] [Commented] (KAFKA-4169) Calculation of message size is too conservative for compressed messages

[ https://issues.apache.org/jira/browse/KAFKA-4169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15490383#comment-15490383 ] Ismael Juma commented on KAFKA-4169: We can't compress before serializing as the compression is done

[jira] [Created] (KAFKA-4169) Calculation of message size is too conservative for compressed messages

Dustin Cote created KAFKA-4169: -- Summary: Calculation of message size is too conservative for compressed messages Key: KAFKA-4169 URL: https://issues.apache.org/jira/browse/KAFKA-4169 Project: Kafka

[jira] [Resolved] (KAFKA-3183) Add metrics for persistent store caching layer

[ https://issues.apache.org/jira/browse/KAFKA-3183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-3183. - Resolution: Duplicate > Add metrics for persistent store caching layer >

[jira] [Created] (KAFKA-4168) More precise accounting of memory usage

Eno Thereska created KAFKA-4168: --- Summary: More precise accounting of memory usage Key: KAFKA-4168 URL: https://issues.apache.org/jira/browse/KAFKA-4168 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-4167) Add cache metrics

Eno Thereska created KAFKA-4167: --- Summary: Add cache metrics Key: KAFKA-4167 URL: https://issues.apache.org/jira/browse/KAFKA-4167 Project: Kafka Issue Type: Sub-task Affects Versions:

[jira] [Created] (KAFKA-4166) TestMirrorMakerService.test_bounce transient system test failure

Ismael Juma created KAFKA-4166: -- Summary: TestMirrorMakerService.test_bounce transient system test failure Key: KAFKA-4166 URL: https://issues.apache.org/jira/browse/KAFKA-4166 Project: Kafka

[jira] [Updated] (KAFKA-3586) Quotas do not revert to default values when override config is deleted

[ https://issues.apache.org/jira/browse/KAFKA-3586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-3586: -- Resolution: Fixed Status: Resolved (was: Patch Available) Fixed under KAFKA-4158. >

[jira] [Commented] (KAFKA-4126) No relevant log when the topic is non-existent

[ https://issues.apache.org/jira/browse/KAFKA-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15490118#comment-15490118 ] Manikumar Reddy commented on KAFKA-4126: [~vahid] I think, I tried by disabling auto.topic.create.

[jira] [Updated] (KAFKA-4165) Add 0.10.0.1 as a source for compatibility tests where relevant

[ https://issues.apache.org/jira/browse/KAFKA-4165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4165: --- Issue Type: Improvement (was: Bug) > Add 0.10.0.1 as a source for compatibility tests where relevant

[jira] [Created] (KAFKA-4165) Add 0.10.0.1 as a source for compatibility tests where relevant

Ismael Juma created KAFKA-4165: -- Summary: Add 0.10.0.1 as a source for compatibility tests where relevant Key: KAFKA-4165 URL: https://issues.apache.org/jira/browse/KAFKA-4165 Project: Kafka

[jira] [Commented] (KAFKA-4126) No relevant log when the topic is non-existent

[ https://issues.apache.org/jira/browse/KAFKA-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15490076#comment-15490076 ] Balázs Barnabás commented on KAFKA-4126: My Scala application sends a ProducerRecord to Kafka the

[jira] [Created] (KAFKA-4164) Kafka produces excessive logs when publishing message to non-existent topic

Vimal Sharma created KAFKA-4164: --- Summary: Kafka produces excessive logs when publishing message to non-existent topic Key: KAFKA-4164 URL: https://issues.apache.org/jira/browse/KAFKA-4164 Project:

[jira] [Work started] (KAFKA-4163) NPE in StreamsMetadataState during re-balance operations

[ https://issues.apache.org/jira/browse/KAFKA-4163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4163 started by Damian Guy. - > NPE in StreamsMetadataState during re-balance operations >

[jira] [Updated] (KAFKA-4163) NPE in StreamsMetadataState during re-balance operations

[ https://issues.apache.org/jira/browse/KAFKA-4163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4163: -- Status: Patch Available (was: In Progress) > NPE in StreamsMetadataState during re-balance operations

[jira] [Created] (KAFKA-4163) NPE in StreamsMetadataState during re-balance operations

Damian Guy created KAFKA-4163: - Summary: NPE in StreamsMetadataState during re-balance operations Key: KAFKA-4163 URL: https://issues.apache.org/jira/browse/KAFKA-4163 Project: Kafka Issue Type:

[GitHub] kafka pull request #1853: Fixed typo "rebalance"

GitHub user mvj3 opened a pull request: https://github.com/apache/kafka/pull/1853 Fixed typo "rebalance" You can merge this pull request into a Git repository by running: $ git pull https://github.com/mvj3/kafka KAFKA-4162 Alternatively you can review and apply these changes

[jira] [Created] (KAFKA-4162) Typo in Kafka Connect document

David Chen created KAFKA-4162: - Summary: Typo in Kafka Connect document Key: KAFKA-4162 URL: https://issues.apache.org/jira/browse/KAFKA-4162 Project: Kafka Issue Type: Bug Components:

[GitHub] kafka pull request #1438: MINOR: Kafka And ZooKeeper Stop Scripts doesn't re...

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