[jira] [Commented] (KAFKA-2985) Consumer group stuck in rebalancing state

[ https://issues.apache.org/jira/browse/KAFKA-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112100#comment-15112100 ] Federico Fissore commented on KAFKA-2985: - My test still shows consumer stuck awai

[jira] [Commented] (KAFKA-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112115#comment-15112115 ] Pierre-Yves Ritschard commented on KAFKA-3006: -- Hi [~gwenshap], I'm happy to

[jira] [Created] (KAFKA-3130) Consistent option names for command-line tools

Ismael Juma created KAFKA-3130: -- Summary: Consistent option names for command-line tools Key: KAFKA-3130 URL: https://issues.apache.org/jira/browse/KAFKA-3130 Project: Kafka Issue Type: Improvem

Re: KIP for extension of SASL to include additional mechanisms

Thank you, Jun. On Fri, Jan 22, 2016 at 4:26 AM, Jun Rao wrote: > Rajini, > > Thanks for your interest. I just gave you the permission to Kafka wiki. > > Jun > > On Thu, Jan 21, 2016 at 5:51 AM, Rajini Sivaram < > rajinisiva...@googlemail.com> wrote: > > > Can I have access to write up a KIP for

[jira] [Commented] (KAFKA-2066) Replace FetchRequest / FetchResponse with their org.apache.kafka.common.requests equivalents

[ https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112285#comment-15112285 ] Ismael Juma commented on KAFKA-2066: [~dajac], I suggest you submit a PR for review on

[GitHub] kafka pull request: Fixed undefined method `update_guest'

GitHub user szwed opened a pull request: https://github.com/apache/kafka/pull/802 Fixed undefined method `update_guest' You can merge this pull request into a Git repository by running: $ git pull https://github.com/szwed/kafka trunk Alternatively you can review and apply the

[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=15112348#comment-15112348 ] Arun Mahadevan commented on KAFKA-3129: --- Are you creating the topic beforehand? It

[jira] [Commented] (KAFKA-1448) Filter-plugins for messages

[ https://issues.apache.org/jira/browse/KAFKA-1448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112349#comment-15112349 ] Stevo Slavic commented on KAFKA-1448: - Would be nice to be able as consumer to pass a

[jira] [Commented] (KAFKA-2066) Replace FetchRequest / FetchResponse with their org.apache.kafka.common.requests equivalents

[ https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112481#comment-15112481 ] Jiangjie Qin commented on KAFKA-2066: - [~dajac] I think it would be better if you can

[GitHub] kafka pull request: KAFKA-3038: use async ZK calls to speed up lea...

Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/750 --- 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-3038) Speeding up partition reassignment after broker failure

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

[jira] [Commented] (KAFKA-3038) Speeding up partition reassignment after broker failure

[ https://issues.apache.org/jira/browse/KAFKA-3038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112507#comment-15112507 ] Eno Thereska commented on KAFKA-3038: - Closing initial PR since there is an opportunit

[jira] [Updated] (KAFKA-3131) Inappropriate logging level for SSL Problem

[ https://issues.apache.org/jira/browse/KAFKA-3131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Robb updated KAFKA-3131: - Component/s: clients > Inappropriate logging level for SSL Problem > -

[jira] [Updated] (KAFKA-3131) Inappropriate logging level for SSL Problem

[ https://issues.apache.org/jira/browse/KAFKA-3131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Robb updated KAFKA-3131: - Description: I didn't have my truststore set up correctly. The Kafka producer waited until the connection

[jira] [Updated] (KAFKA-3131) Inappropriate logging level for SSL Problem

[ https://issues.apache.org/jira/browse/KAFKA-3131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Robb updated KAFKA-3131: - Description: I didn't have my truststore set up correctly. The Kafka producer waited until the connection

[jira] [Updated] (KAFKA-3131) Inappropriate logging level for SSL Problem

[ https://issues.apache.org/jira/browse/KAFKA-3131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Robb updated KAFKA-3131: - Attachment: kafka-ssl-error-debug-log.txt > Inappropriate logging level for SSL Problem >

[jira] [Assigned] (KAFKA-3131) Inappropriate logging level for SSL Problem

[ https://issues.apache.org/jira/browse/KAFKA-3131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani reassigned KAFKA-3131: - Assignee: Sriharsha Chintalapani > Inappropriate logging level for SSL Pr

[jira] [Updated] (KAFKA-3131) Inappropriate logging level for SSL Problem

[ https://issues.apache.org/jira/browse/KAFKA-3131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Robb updated KAFKA-3131: - Description: I didn't have my truststore set up correctly. The Kafka producer waited until the connection

[jira] [Created] (KAFKA-3131) Inappropriate logging level for SSL Problem

Jake Robb created KAFKA-3131: Summary: Inappropriate logging level for SSL Problem Key: KAFKA-3131 URL: https://issues.apache.org/jira/browse/KAFKA-3131 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-3132) Protocols in "listeners" property should not be case-sensitive

Jake Robb created KAFKA-3132: Summary: Protocols in "listeners" property should not be case-sensitive Key: KAFKA-3132 URL: https://issues.apache.org/jira/browse/KAFKA-3132 Project: Kafka Issue T

[jira] [Updated] (KAFKA-3132) URI scheme in "listeners" property should not be case-sensitive

[ https://issues.apache.org/jira/browse/KAFKA-3132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Robb updated KAFKA-3132: - Summary: URI scheme in "listeners" property should not be case-sensitive (was: Protocols in "listeners" p

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112574#comment-15112574 ] Eno Thereska commented on KAFKA-3068: - We'll go with keeping the original bootstrap br

[jira] [Commented] (KAFKA-2066) Replace FetchRequest / FetchResponse with their org.apache.kafka.common.requests equivalents

[ https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112619#comment-15112619 ] David Jacot commented on KAFKA-2066: [~becket_qin] That makes sense. I'll take a look

[jira] [Commented] (KAFKA-3061) Get rid of Guava dependency

[ https://issues.apache.org/jira/browse/KAFKA-3061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112729#comment-15112729 ] Ewen Cheslack-Postava commented on KAFKA-3061: -- [~ijuma] I think they could i

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112787#comment-15112787 ] Ewen Cheslack-Postava commented on KAFKA-3068: -- I'm thinking more about this

[jira] [Commented] (KAFKA-3126) Weird behavior in kafkaController on Controlled shutdowns. The leaderAndIsr in zookeeper is not updated during controlled shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-3126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112795#comment-15112795 ] Mayuresh Gharat commented on KAFKA-3126: My confusion as described in this jira wa

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112810#comment-15112810 ] Ismael Juma commented on KAFKA-3068: [~ewencp], that sounds like a worthwhile improvem

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112812#comment-15112812 ] Eno Thereska commented on KAFKA-3068: - [~ewencp]: sounds like a KIP? In the old Kafka

[jira] [Created] (KAFKA-3133) Add putIfAbsent function to KeyValueStore

Guozhang Wang created KAFKA-3133: Summary: Add putIfAbsent function to KeyValueStore Key: KAFKA-3133 URL: https://issues.apache.org/jira/browse/KAFKA-3133 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-3132) URI scheme in "listeners" property should not be case-sensitive

[ https://issues.apache.org/jira/browse/KAFKA-3132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3132: Labels: newbie (was: ) > URI scheme in "listeners" property should not be case-sensitive >

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112863#comment-15112863 ] Ewen Cheslack-Postava commented on KAFKA-3068: -- [~enothereska] [~ijuma] Agree

Re: Pluggable Log Compaction Policy

A function such as "deleteUpToOffset(TopicPartition tp, long minOffsetToRetain)" exposed through AdminUtils would be perfect. I would agree that a one-time admin tool would be a good fit for our use case, as long as we can programmatically invoke it. I realize that isn't completely trivial, since

[jira] [Commented] (KAFKA-3126) Weird behavior in kafkaController on Controlled shutdowns. The leaderAndIsr in zookeeper is not updated during controlled shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-3126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112883#comment-15112883 ] Jiangjie Qin commented on KAFKA-3126: - That is exactly what I said. You see difference

[jira] [Created] (KAFKA-3134) Missing required configuration "value.deserializer" when initializing a KafkaConsumer with a valid "valueDeserializer"

Yifan Ying created KAFKA-3134: - Summary: Missing required configuration "value.deserializer" when initializing a KafkaConsumer with a valid "valueDeserializer" Key: KAFKA-3134 URL: https://issues.apache.org/jira/brows

[jira] [Updated] (KAFKA-3134) Missing required configuration "value.deserializer" when initializing a KafkaConsumer with a valid "valueDeserializer"

[ https://issues.apache.org/jira/browse/KAFKA-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Ying updated KAFKA-3134: -- Description: I tried to initialize a KafkaConsumer object using with a null keyDeserializer and a non-n

[jira] [Updated] (KAFKA-3134) Missing required configuration "value.deserializer" when initializing a KafkaConsumer with a valid "valueDeserializer"

[ https://issues.apache.org/jira/browse/KAFKA-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yifan Ying updated KAFKA-3134: -- Description: I tried to initialize a KafkaConsumer object using with a null keyDeserializer and a non-n

[jira] [Commented] (KAFKA-3130) Consistent option names for command-line tools

[ https://issues.apache.org/jira/browse/KAFKA-3130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112901#comment-15112901 ] Gwen Shapira commented on KAFKA-3130: - See KIP-14 > Consistent option names for comma

[jira] [Commented] (KAFKA-2985) Consumer group stuck in rebalancing state

[ https://issues.apache.org/jira/browse/KAFKA-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112904#comment-15112904 ] Jason Gustafson commented on KAFKA-2985: [~fridrik] I ran your test above a coupl

[jira] [Resolved] (KAFKA-3130) Consistent option names for command-line tools

[ https://issues.apache.org/jira/browse/KAFKA-3130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3130. Resolution: Duplicate Thanks [~gwenshap], I missed that KIP. Do you know if anyone is still planning

[jira] [Commented] (KAFKA-3134) Missing required configuration "value.deserializer" when initializing a KafkaConsumer with a valid "valueDeserializer"

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

[jira] [Commented] (KAFKA-3130) Consistent option names for command-line tools

[ https://issues.apache.org/jira/browse/KAFKA-3130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112918#comment-15112918 ] Gwen Shapira commented on KAFKA-3130: - AFAIK, no one is working on it at the moment.

[GitHub] kafka pull request: KAFKA-3134: Fix missing value.deserializer err...

GitHub user happymap opened a pull request: https://github.com/apache/kafka/pull/803 KAFKA-3134: Fix missing value.deserializer error during KafkaConsumer… … initialization You can merge this pull request into a Git repository by running: $ git pull https://github.com/happy

[jira] [Commented] (KAFKA-3130) Consistent option names for command-line tools

[ https://issues.apache.org/jira/browse/KAFKA-3130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15112928#comment-15112928 ] Jiangjie Qin commented on KAFKA-3130: - [~ijuma] I don't think anyone's working on it.

[jira] [Created] (KAFKA-3135) Unexpected delay before fetch response transmission

Jason Gustafson created KAFKA-3135: -- Summary: Unexpected delay before fetch response transmission Key: KAFKA-3135 URL: https://issues.apache.org/jira/browse/KAFKA-3135 Project: Kafka Issue T

[jira] [Updated] (KAFKA-3135) Unexpected delay before fetch response transmission

[ https://issues.apache.org/jira/browse/KAFKA-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-3135: --- Affects Version/s: 0.9.0.0 > Unexpected delay before fetch response transmission > ---

Re: Pluggable Log Compaction Policy

Bill, Sounds good. If you want to drive pushing this feature, you can try to first submit a KIP proposal: https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals This admin command may have some correlations with KIP-4: https://cwiki.apache.org/confluence/display/KAFKA/KIP

[GitHub] kafka pull request: KAFKA-3068: Keep track of bootstrap nodes inst...

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/804 KAFKA-3068: Keep track of bootstrap nodes instead of all nodes ever seen You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka ka

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

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

[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=15113016#comment-15113016 ] Vahid Hashemian commented on KAFKA-3129: Yes, I'm creating the topic before trying

[jira] [Created] (KAFKA-3136) Rename KafkaStreaming to KafkaStreams

Guozhang Wang created KAFKA-3136: Summary: Rename KafkaStreaming to KafkaStreams Key: KAFKA-3136 URL: https://issues.apache.org/jira/browse/KAFKA-3136 Project: Kafka Issue Type: Sub-task

[GitHub] kafka pull request: KAFKA-3136: Rename KafkaStreaming to KafkaStre...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/800 --- 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-3136) Rename KafkaStreaming to KafkaStreams

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

[jira] [Updated] (KAFKA-3136) Rename KafkaStreaming to KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-3136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3136: - Description: To be aligned with the module name. Also change the config / metrics class names acc

[jira] [Resolved] (KAFKA-3136) Rename KafkaStreaming to KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-3136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-3136. - Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull request 800 [https://github

[jira] [Commented] (KAFKA-1860) File system errors are not detected unless Kafka tries to write

[ https://issues.apache.org/jira/browse/KAFKA-1860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113128#comment-15113128 ] Mayuresh Gharat commented on KAFKA-1860: [~guozhang] can you take another look at

[jira] [Resolved] (KAFKA-1796) Sanity check partition command line tools

[ https://issues.apache.org/jira/browse/KAFKA-1796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat resolved KAFKA-1796. Resolution: Not A Problem > Sanity check partition command line tools >

[jira] [Created] (KAFKA-3137) Delete tombstones in log compacted topics may never get removed.

James Cheng created KAFKA-3137: -- Summary: Delete tombstones in log compacted topics may never get removed. Key: KAFKA-3137 URL: https://issues.apache.org/jira/browse/KAFKA-3137 Project: Kafka I

[jira] [Commented] (KAFKA-3132) URI scheme in "listeners" property should not be case-sensitive

[ https://issues.apache.org/jira/browse/KAFKA-3132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113143#comment-15113143 ] Vahid Hashemian commented on KAFKA-3132: When I use the lowercase "plaintext" and

[jira] [Created] (KAFKA-3138) 0.9.0 docs still say that log compaction doesn't work on compressed topics.

James Cheng created KAFKA-3138: -- Summary: 0.9.0 docs still say that log compaction doesn't work on compressed topics. Key: KAFKA-3138 URL: https://issues.apache.org/jira/browse/KAFKA-3138 Project: Kafka

[jira] [Comment Edited] (KAFKA-3132) URI scheme in "listeners" property should not be case-sensitive

[ https://issues.apache.org/jira/browse/KAFKA-3132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113143#comment-15113143 ] Vahid Hashemian edited comment on KAFKA-3132 at 1/22/16 9:41 PM: ---

[jira] [Updated] (KAFKA-3138) 0.9.0 docs still say that log compaction doesn't work on compressed topics.

[ https://issues.apache.org/jira/browse/KAFKA-3138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng updated KAFKA-3138: --- Description: The 0.9.0 docs say "Log compaction is not yet compatible with compressed topics.". But I

[jira] [Created] (KAFKA-3139) JMX metric ProducerRequestPurgatory doesn't exist, docs seem wrong.

James Cheng created KAFKA-3139: -- Summary: JMX metric ProducerRequestPurgatory doesn't exist, docs seem wrong. Key: KAFKA-3139 URL: https://issues.apache.org/jira/browse/KAFKA-3139 Project: Kafka

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

See Changes: [cshapi] KAFKA-3136: Rename KafkaStreaming to KafkaStreams -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu3 (Ubuntu ubuntu l

[jira] [Commented] (KAFKA-3138) 0.9.0 docs still say that log compaction doesn't work on compressed topics.

[ https://issues.apache.org/jira/browse/KAFKA-3138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113217#comment-15113217 ] Ismael Juma commented on KAFKA-3138: Go for it. :) > 0.9.0 docs still say that log co

[jira] [Commented] (KAFKA-3137) Delete tombstones in log compacted topics may never get removed.

[ https://issues.apache.org/jira/browse/KAFKA-3137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113222#comment-15113222 ] Jay Kreps commented on KAFKA-3137: -- We maintain the modification timestamp from the origi

[GitHub] kafka pull request: MINOR: Fixes version lookup exception.

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/748 --- 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-3140) PatternSyntaxException thrown in MM, causes MM to hang

Ashish K Singh created KAFKA-3140: - Summary: PatternSyntaxException thrown in MM, causes MM to hang Key: KAFKA-3140 URL: https://issues.apache.org/jira/browse/KAFKA-3140 Project: Kafka Issue

[GitHub] kafka pull request: KAFKA-3140: Fix PatternSyntaxException and han...

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/805 KAFKA-3140: Fix PatternSyntaxException and hand caused by it in Mirro… Fix PatternSyntaxException and hand caused by it in MirrorMaker on passing invalid java regex string as whitelist You can

[jira] [Commented] (KAFKA-3140) PatternSyntaxException thrown in MM, causes MM to hang

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

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

See Changes: [me] MINOR: Fixes version lookup exception. -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H10 (Ubuntu ubuntu) in workspace

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113283#comment-15113283 ] Ashish K Singh commented on KAFKA-1696: --- [~harsha_ch] [~parth.brahmbhatt] [~gwenshap

Jenkins build is back to normal : kafka-trunk-jdk8 #305

See

[jira] [Commented] (KAFKA-3061) Get rid of Guava dependency

[ https://issues.apache.org/jira/browse/KAFKA-3061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113293#comment-15113293 ] Ismael Juma commented on KAFKA-3061: Your suggestion to wait for feedback to see if it

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113294#comment-15113294 ] Gwen Shapira commented on KAFKA-1696: - I am not working on it, so you guys figure out

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113295#comment-15113295 ] Parth Brahmbhatt commented on KAFKA-1696: - I will assign it to my self and file a

[jira] [Assigned] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Parth Brahmbhatt reassigned KAFKA-1696: --- Assignee: Parth Brahmbhatt (was: Sriharsha Chintalapani) > Kafka should be able to g

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113297#comment-15113297 ] Ashish K Singh commented on KAFKA-1696: --- Thanks [~gwenshap], [~parth.brahmbhatt]! Lo

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

See Changes: [me] MINOR: Fixes version lookup exception. -- [...truncated 81 lines...] /x1/jenkins/jenkins-slave/workspace/kafka-trunk-jdk8/core/src/main/scala/kafka/server/KafkaServer.scala:305:

[GitHub] kafka pull request: KAFKA-3066: Demo Examples for Kafka Streams

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/797 --- 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-3066) Add Demo Examples for Kafka Streams

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

[jira] [Commented] (KAFKA-3066) Add Demo Examples for Kafka Streams

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

[jira] [Commented] (KAFKA-2426) A Kafka node tries to connect to itself through its advertised hostname

[ https://issues.apache.org/jira/browse/KAFKA-2426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113338#comment-15113338 ] Alex Loddengaard commented on KAFKA-2426: - Hi [~mcluseau], I've been looking into

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

See Changes: [me] KAFKA-3066: Demo Examples for Kafka Streams -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu3 (Ubuntu ubuntu legacy-ubun

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

See Changes: [me] KAFKA-3066: Demo Examples for Kafka Streams -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (docker Ubuntu ubuntu yahoo-no

[jira] [Created] (KAFKA-3141) kafka-acls.sh throws ArrayIndexOutOfBoundsException for an invalid authorizer-property

Ashish K Singh created KAFKA-3141: - Summary: kafka-acls.sh throws ArrayIndexOutOfBoundsException for an invalid authorizer-property Key: KAFKA-3141 URL: https://issues.apache.org/jira/browse/KAFKA-3141

[GitHub] kafka pull request: KAFKA-3140: Fix PatternSyntaxException and han...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/805 --- 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-3140) PatternSyntaxException thrown in MM, causes MM to hang

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

[GitHub] kafka pull request: KAFKA-3141: Skip misformed properties instead ...

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/806 KAFKA-3141: Skip misformed properties instead of throwing ArrayIndexO… Skip misformed properties instead of throwing ArrayIndexOutOfBoundsException You can merge this pull request into a Git rep

[jira] [Resolved] (KAFKA-3140) PatternSyntaxException thrown in MM, causes MM to hang

[ https://issues.apache.org/jira/browse/KAFKA-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-3140. - Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull request 805 [https://github

[jira] [Commented] (KAFKA-3141) kafka-acls.sh throws ArrayIndexOutOfBoundsException for an invalid authorizer-property

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

[DISCUSS] KIP-42: Add Producer and Consumer Interceptors

Hi, I just created a KIP-42 for adding producer and consumer interceptors for intercepting messages at different points on producer and consumer. https://cwiki.apache.org/confluence/display/KAFKA/KIP-42%3A+Add+Producer+and+Consumer+Interceptors Comments and suggestions are welcome! Thanks, Anna

[jira] [Commented] (KAFKA-3110) can't set cluster acl for a user to CREATE topics without first creating a topic

[ https://issues.apache.org/jira/browse/KAFKA-3110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113405#comment-15113405 ] Ashish K Singh commented on KAFKA-3110: --- [~tgraves] i have done this with trunk with

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

See Changes: [cshapi] KAFKA-3140: Fix PatternSyntaxException and hand caused by it in Mirro… -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on

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

See Changes: [cshapi] KAFKA-3140: Fix PatternSyntaxException and hand caused by it in Mirro… -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on

Re: [DISCUSS] KIP-42: Add Producer and Consumer Interceptors

Anna, I'm trying to understand a concrete use case. It sounds like producer interceptors could be used to implement part of LinkedIn's Kafak Audit tool? https://engineering.linkedin.com/kafka/running-kafka-scale Part of that is done by a wrapper library around the kafka producer that keeps a c

Re: [DISCUSS] KIP-42: Add Producer and Consumer Interceptors

James, That is one of the many monitoring use cases for the interceptor interface. Thanks, Neha On Fri, Jan 22, 2016 at 6:18 PM, James Cheng wrote: > Anna, > > I'm trying to understand a concrete use case. It sounds like producer > interceptors could be used to implement part of LinkedIn's Kaf

[jira] [Commented] (KAFKA-3137) Delete tombstones in log compacted topics may never get removed.

[ https://issues.apache.org/jira/browse/KAFKA-3137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15113521#comment-15113521 ] James Cheng commented on KAFKA-3137: Ah, I see the code. I'll run a test with a log co