[jira] [Created] (KAFKA-3226) Replicas collections should use List instead of Set in order to maintain order

Grant Henke created KAFKA-3226: -- Summary: Replicas collections should use List instead of Set in order to maintain order Key: KAFKA-3226 URL: https://issues.apache.org/jira/browse/KAFKA-3226 Project:

[GitHub] kafka pull request: KAFKA-3219: Fix long topic name validation

GitHub user vahidhashemian opened a pull request: https://github.com/apache/kafka/pull/898 KAFKA-3219: Fix long topic name validation This fixes an issue with long topic names by considering, during topic validation, the '-' and the partition id that is appended to the log

[GitHub] kafka pull request: MINOR: add retry to state dir locking

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/899 MINOR: add retry to state dir locking There is a possibility that the state directory locking fails when another stream thread is taking long to close all tasks. Simple retries should alleviate

[jira] [Commented] (KAFKA-3219) Long topic names mess up broker topic state

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

[GitHub] kafka pull request: KAFKA-3226: Replicas collections should use Li...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/900 KAFKA-3226: Replicas collections should use List instead of Set in or… …der to maintain order You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (KAFKA-3226) Replicas collections should use List instead of Set in order to maintain order

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

[GitHub] kafka pull request: MINOR: Remove multi-byte charactor in docs

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/897 --- 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] [Updated] (KAFKA-3219) Long topic names mess up broker topic state

[ https://issues.apache.org/jira/browse/KAFKA-3219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-3219: --- Status: Patch Available (was: Open) > Long topic names mess up broker topic state >

[jira] [Updated] (KAFKA-3226) Replicas collections should use List instead of Set in order to maintain order

[ https://issues.apache.org/jira/browse/KAFKA-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3226: --- Status: Patch Available (was: Open) > Replicas collections should use List instead of Set in order

[jira] [Commented] (KAFKA-3225) Method commit() of class SourceTask never invoked

[ https://issues.apache.org/jira/browse/KAFKA-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15141544#comment-15141544 ] Gwen Shapira commented on KAFKA-3225: - Good catch. This is a bit embarrassing... we didn't have a

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

See Changes: [cshapi] MINOR: Remove multi-byte charactor in docs -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu3 (Ubuntu ubuntu

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

See

[GitHub] kafka pull request: KAFKA-3153: KStream,Type and Serialization

Github user ymatsuda closed the pull request at: https://github.com/apache/kafka/pull/794 --- 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-3153) Serializer/Deserializer Registration and Type inference

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

[GitHub] kafka pull request: HOTFIX: poll even when all partitions are paus...

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

KafkaConsumer.poll(long) pauses indefinitely

Hi, I'm noticing that when we have a thread that comes up and calls KafkaConsumer.poll(long), it will pause for a much longer time than our 1s timeout. It looks like this is probably happening when kafka gets down to calling ConsumerNetworkClient.epollWait after calling

[jira] [Updated] (KAFKA-2590) KIP-28: Kafka Streams Checklist

[ https://issues.apache.org/jira/browse/KAFKA-2590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2590: - Summary: KIP-28: Kafka Streams Checklist (was: Kafka Streams Checklist) > KIP-28: Kafka Streams

[jira] [Updated] (KAFKA-3226) Replicas collections should use List instead of Set in order to maintain order

[ https://issues.apache.org/jira/browse/KAFKA-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3226: --- Resolution: Not A Problem Fix Version/s: (was: 0.9.0.1) Status: Resolved (was:

[GitHub] kafka pull request: MINOR: catch an exception in rebalance and sto...

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/901 MINOR: catch an exception in rebalance and stop the stream thread You can merge this pull request into a Git repository by running: $ git pull https://github.com/ymatsuda/kafka minor3

[jira] [Commented] (KAFKA-3226) Replicas collections should use List instead of Set in order to maintain order

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

[GitHub] kafka pull request: KAFKA-3226: Replicas collections should use Li...

Github user granthenke closed the pull request at: https://github.com/apache/kafka/pull/900 --- 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-3052) broker properties get logged twice if acl is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15142015#comment-15142015 ] Mark Grover commented on KAFKA-3052: Hi all, this seems like a very good change, thanks for working on

[GitHub] kafka pull request: MINOR: connect hangs on startup failure

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/902 MINOR: connect hangs on startup failure You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka hotfix-connect-startup Alternatively

[jira] [Comment Edited] (KAFKA-3052) broker properties get logged twice if acl is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15142015#comment-15142015 ] Mark Grover edited comment on KAFKA-3052 at 2/11/16 12:24 AM: -- Hi all, this

[jira] [Commented] (KAFKA-3052) broker properties get logged twice if acl is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15142034#comment-15142034 ] Ismael Juma commented on KAFKA-3052: Hi Mark, we also added a secondary constructor to maintain

[jira] [Commented] (KAFKA-3052) broker properties get logged twice if acl is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15142041#comment-15142041 ] Mark Grover commented on KAFKA-3052: Ah, thanks Ismael. My kafka code was in the small window in

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

See Changes: [me] MINOR: add setUncaughtExceptionHandler to KafkaStreams -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (docker Ubuntu

[GitHub] kafka pull request: MINOR: add setUncaughtExceptionHandler to Kafk...

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

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

See Changes: [me] MINOR: add setUncaughtExceptionHandler to KafkaStreams -- [...truncated 7086 lines...] org.apache.kafka.connect.runtime.rest.resources.ConnectorsResourceTest >

[jira] [Created] (KAFKA-3225) Method commit() of class SourceTask never invoked

Krzysztof Dębski created KAFKA-3225: --- Summary: Method commit() of class SourceTask never invoked Key: KAFKA-3225 URL: https://issues.apache.org/jira/browse/KAFKA-3225 Project: Kafka Issue

[GitHub] kafka pull request: MINOR: Remove multi-byte charactor in docs

GitHub user sasakitoa opened a pull request: https://github.com/apache/kafka/pull/897 MINOR: Remove multi-byte charactor in docs There are multi-byte characters In quickstart.html and security.html. This PR will fix it. You can merge this pull request into a Git repository by

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

See Changes: [cshapi] HOTFIX: poll even when all partitions are paused. handle concurrent -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on

Re: [DISCUSS] KIP-47 - Add timestamp-based log deletion policy

I think this makes a lot of sense and won't be hard to implement and doesn't create too much in the way of new interfaces. -Jay On Tue, Feb 9, 2016 at 8:13 AM, Bill Warshaw wrote: > Hello, > > I just submitted KIP-47 for adding a new log deletion policy based on a >

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

See Changes: [cshapi] HOTFIX: poll even when all partitions are paused. handle concurrent -- [...truncated 6784 lines...] org.apache.kafka.connect.runtime.rest.resources.ConnectorsResourceTest >

[jira] [Commented] (KAFKA-3052) broker properties get logged twice if acl is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15142096#comment-15142096 ] Ismael Juma commented on KAFKA-3052: Great, Mark. Thank you for checking, we do appreciate it! >

[GitHub] kafka pull request: MINOR: connect hangs on startup failure

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

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

See Changes: [me] MINOR: Connect hangs on startup failure -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu3 (Ubuntu ubuntu

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

See Changes: [me] MINOR: Connect hangs on startup failure -- [...truncated 6699 lines...] org.apache.kafka.connect.runtime.rest.resources.ConnectorsResourceTest >