[jira] [Created] (KAFKA-6871) KStreams Scala API: incorrect Javadocs and misleading parameter name

2018-05-07 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-6871: --- Summary: KStreams Scala API: incorrect Javadocs and misleading parameter name Key: KAFKA-6871 URL: https://issues.apache.org/jira/browse/KAFKA-6871 Project: Kafka

[jira] [Created] (KAFKA-5636) DSL: allow sliding windows to be used directly (i.e. not just implicitly when doing joins)

2017-07-25 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-5636: --- Summary: DSL: allow sliding windows to be used directly (i.e. not just implicitly when doing joins) Key: KAFKA-5636 URL: https://issues.apache.org/jira/browse/KAFKA-5636

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

2017-05-02 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15993467#comment-15993467 ] Michael Noll commented on KAFKA-1194: - [~guozhang]: Do you happen to know the latest status of this

[jira] [Updated] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

2017-05-01 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-5146: Description: We currently have a compile-dependency on `connect-json`: {code} org.apache.kafka

[jira] [Updated] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

2017-05-01 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-5146: Affects Version/s: 0.10.2.1 0.10.1.0 0.10.2.0 > Kafka

[jira] [Updated] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

2017-05-01 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-5146: Description: We currently have a compile-dependency on `connect-json`: {code} org.apache.kafka

[jira] [Updated] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

2017-05-01 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-5146: Description: We currently have a compile-dependency on `connect-json`: {code} org.apache.kafka

[jira] [Created] (KAFKA-5146) Kafka Streams: remove compile dependency on connect-json

2017-05-01 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-5146: --- Summary: Kafka Streams: remove compile dependency on connect-json Key: KAFKA-5146 URL: https://issues.apache.org/jira/browse/KAFKA-5146 Project: Kafka Issue

[jira] [Commented] (KAFKA-4144) Allow per stream/table timestamp extractor

2017-04-26 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15984230#comment-15984230 ] Michael Noll commented on KAFKA-4144: - As part of this work we should also update the respective Kafka

[jira] [Updated] (KAFKA-4791) Kafka Streams - unable to add state stores when using wildcard topics on the source

2017-03-21 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-4791: Affects Version/s: 0.10.2.0 > Kafka Streams - unable to add state stores when using wildcard topics

[jira] [Commented] (KAFKA-4609) KTable/KTable join followed by groupBy and aggregate/count can result in incorrect results

2017-03-14 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15924093#comment-15924093 ] Michael Noll commented on KAFKA-4609: - Care to elaborate [~damianguy]? Why does this happen only when

[jira] [Commented] (KAFKA-4880) Add KTable/GlobalKTable Join to Streams

2017-03-10 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904745#comment-15904745 ] Michael Noll commented on KAFKA-4880: - FWIW, I wonder how much interest there actually is for this

[jira] [Commented] (KAFKA-4835) Allow users control over repartitioning

2017-03-10 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15904709#comment-15904709 ] Michael Noll commented on KAFKA-4835: - Just to clarify: {quote} However, in our case I know that both

[jira] [Updated] (KAFKA-4875) Kafka Streams: topic groups and builder.stream API

2017-03-09 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-4875: Summary: Kafka Streams: topic groups and builder.stream API (was: Kafka streams topic groups and

[jira] [Commented] (KAFKA-4875) Kafka streams topic groups and builder.stream API

2017-03-09 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15902975#comment-15902975 ] Michael Noll commented on KAFKA-4875: - There two things at play here IMHO: 1. Whether or not there's

[jira] [Created] (KAFKA-4836) Kafka Streams app reset tool: support wildcards for topics

2017-03-03 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-4836: --- Summary: Kafka Streams app reset tool: support wildcards for topics Key: KAFKA-4836 URL: https://issues.apache.org/jira/browse/KAFKA-4836 Project: Kafka Issue

[jira] [Updated] (KAFKA-4769) Add Float serializer, deserializer, serde

2017-02-15 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-4769: Status: Patch Available (was: Open) > Add Float serializer, deserializer, serde >

[jira] [Created] (KAFKA-4769) Add Float serializer, deserializer, serde

2017-02-15 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-4769: --- Summary: Add Float serializer, deserializer, serde Key: KAFKA-4769 URL: https://issues.apache.org/jira/browse/KAFKA-4769 Project: Kafka Issue Type:

[jira] [Comment Edited] (KAFKA-3705) Support non-key joining in KTable

2017-01-17 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15826064#comment-15826064 ] Michael Noll edited comment on KAFKA-3705 at 1/17/17 1:48 PM: -- [~jfilipiak]:

[jira] [Commented] (KAFKA-3705) Support non-key joining in KTable

2017-01-17 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15826064#comment-15826064 ] Michael Noll commented on KAFKA-3705: - [~jfilipiak]: Now that support for global KTables is around the

[jira] [Commented] (KAFKA-3745) Consider adding join key to ValueJoiner interface

2017-01-12 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15821054#comment-15821054 ] Michael Noll commented on KAFKA-3745: - I think [~mjsax] meant to say "not a big deal" (rather than

[jira] [Commented] (KAFKA-4614) Long GC pause harming broker performance which is caused by mmap objects created for OffsetIndex

2017-01-12 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15820875#comment-15820875 ] Michael Noll commented on KAFKA-4614: - [~kawamuray] Sorry to hear that you ran into this. Thanks a

[jira] [Commented] (KAFKA-4316) Kafka Streams 0.10.0.1 does not run on Windows x64

2016-10-19 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15589806#comment-15589806 ] Michael Noll commented on KAFKA-4316: - [~habdank]: Sounds good. FYI: The vote on releasing Kafka

[jira] [Updated] (KAFKA-4316) Kafka Streams 0.10.0.1 does not run on Windows x64

2016-10-19 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-4316: Description: We had encountered the problem that starting application with Kafka Streams 0.10.0.1

[jira] [Updated] (KAFKA-4316) Kafka Streams 0.10.0.1 does not run on Windows x64

2016-10-19 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-4316: Description: We had encountered the problem that starting application with Kafka Streams 0.10.0.1

[jira] [Commented] (KAFKA-4316) Kafka Streams 0.10.0.1 does not run on Windows x64

2016-10-19 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15588149#comment-15588149 ] Michael Noll commented on KAFKA-4316: - [~habdank]: Thanks for reporting this. FYI: The upcoming

[jira] [Commented] (KAFKA-3973) Investigate feasibility of caching bytes vs. records

2016-07-25 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15391519#comment-15391519 ] Michael Noll commented on KAFKA-3973: - +1 to having repeatable tests/benchmarks (e.g. with JMH). >

[jira] [Updated] (KAFKA-3478) Finer Stream Flow Control

2016-07-05 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-3478: Description: Today we have a event-time based flow control mechanism in order to synchronize

[jira] [Updated] (KAFKA-3805) Running multiple instances of a Streams app on the same machine results in Java_org_rocksdb_RocksDB_write error

2016-06-08 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-3805: Summary: Running multiple instances of a Streams app on the same machine results in

[jira] [Commented] (KAFKA-3478) Finer Stream Flow Control

2016-05-30 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15306409#comment-15306409 ] Michael Noll commented on KAFKA-3478: - Latest documentation link (covers flow control with timestamps

[jira] [Commented] (KAFKA-3646) Console producer using new producer should set timestamp

2016-05-01 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15266129#comment-15266129 ] Michael Noll commented on KAFKA-3646: - We should also think about whether a negative timestamp (-1)

[jira] [Work started] (KAFKA-3613) Consolidate tumbling windows and hopping windows

2016-04-27 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3613 started by Michael Noll. --- > Consolidate tumbling windows and hopping windows >

[jira] [Assigned] (KAFKA-3613) Consolidate tumbling windows and hopping windows

2016-04-27 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll reassigned KAFKA-3613: --- Assignee: Michael Noll > Consolidate tumbling windows and hopping windows >

[jira] [Updated] (KAFKA-3614) Consolidate duplicate code in KGroupedTableImpl

2016-04-23 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-3614: Description: The implementations of aggregate() and reduce() in KGroupedTableImpl are essentially

[jira] [Created] (KAFKA-3614) Consolidate duplicate code in KGroupedTableImpl

2016-04-23 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-3614: --- Summary: Consolidate duplicate code in KGroupedTableImpl Key: KAFKA-3614 URL: https://issues.apache.org/jira/browse/KAFKA-3614 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-3613) Consolidate tumbling windows and hopping windows

2016-04-23 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-3613: --- Summary: Consolidate tumbling windows and hopping windows Key: KAFKA-3613 URL: https://issues.apache.org/jira/browse/KAFKA-3613 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-3511) Provide built-in aggregators sum() and avg() in Kafka Streams DSL

2016-04-12 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15237291#comment-15237291 ] Michael Noll commented on KAFKA-3511: - [~guozhang]: Could we leverage the parent class

[jira] [Comment Edited] (KAFKA-3499) byte[] should not be used as Map key nor Set member

2016-04-11 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235799#comment-15235799 ] Michael Noll edited comment on KAFKA-3499 at 4/11/16 8:05 PM: -- FWIW, we ran

[jira] [Comment Edited] (KAFKA-3522) Consider adding version information into rocksDB storage format

2016-04-11 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235814#comment-15235814 ] Michael Noll edited comment on KAFKA-3522 at 4/11/16 7:41 PM: -- [~jkreps]

[jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format

2016-04-11 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235814#comment-15235814 ] Michael Noll commented on KAFKA-3522: - [~jkreps] wrote: {quote} I think you could potentially just

[jira] [Comment Edited] (KAFKA-3499) byte[] should not be used as Map key nor Set member

2016-04-11 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235799#comment-15235799 ] Michael Noll edited comment on KAFKA-3499 at 4/11/16 7:35 PM: -- FWIW, we ran

[jira] [Commented] (KAFKA-3499) byte[] should not be used as Map key nor Set member

2016-04-11 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235799#comment-15235799 ] Michael Noll commented on KAFKA-3499: - FWIW, we ran into the same problem when handling byte[] in

[jira] [Commented] (KAFKA-3511) Provide built-in aggregators sum() and avg() in Kafka Streams DSL

2016-04-11 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235113#comment-15235113 ] Michael Noll commented on KAFKA-3511: - PS: As [~guozhang] hinted at, we should also keep in mind that

[jira] [Comment Edited] (KAFKA-3511) Provide built-in aggregators sum() and avg() in Kafka Streams DSL

2016-04-11 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235113#comment-15235113 ] Michael Noll edited comment on KAFKA-3511 at 4/11/16 1:54 PM: -- PS: As

[jira] [Comment Edited] (KAFKA-3511) Provide built-in aggregators sum() and avg() in Kafka Streams DSL

2016-04-11 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15234770#comment-15234770 ] Michael Noll edited comment on KAFKA-3511 at 4/11/16 9:08 AM: -- Hmm. I'd

[jira] [Comment Edited] (KAFKA-3511) Provide built-in aggregators sum() and avg() in Kafka Streams DSL

2016-04-11 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15234770#comment-15234770 ] Michael Noll edited comment on KAFKA-3511 at 4/11/16 9:07 AM: -- Hmm. I'd

[jira] [Comment Edited] (KAFKA-3511) Provide built-in aggregators sum() and avg() in Kafka Streams DSL

2016-04-11 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15234770#comment-15234770 ] Michael Noll edited comment on KAFKA-3511 at 4/11/16 9:05 AM: -- Hmm. I'd

[jira] [Commented] (KAFKA-3511) Provide built-in aggregators sum() and avg() in Kafka Streams DSL

2016-04-11 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15234770#comment-15234770 ] Michael Noll commented on KAFKA-3511: - Hmm. I'd prefer an API that allows me to write: *

[jira] [Updated] (KAFKA-3449) Rename filterOut() to filterNot() to achieve better terminology

2016-03-23 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-3449: Fix Version/s: 0.10.0.1 > Rename filterOut() to filterNot() to achieve better terminology >

[jira] [Created] (KAFKA-3449) Rename filterOut() to filterNot() to achieve better terminology

2016-03-23 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-3449: --- Summary: Rename filterOut() to filterNot() to achieve better terminology Key: KAFKA-3449 URL: https://issues.apache.org/jira/browse/KAFKA-3449 Project: Kafka

[jira] [Created] (KAFKA-3411) Streams: rename job.id to application.id

2016-03-16 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-3411: --- Summary: Streams: rename job.id to application.id Key: KAFKA-3411 URL: https://issues.apache.org/jira/browse/KAFKA-3411 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-3411) Streams: stop using "job" terminology, rename job.id to application.id

2016-03-16 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-3411: Summary: Streams: stop using "job" terminology, rename job.id to application.id (was: Streams:

[jira] [Updated] (KAFKA-3324) NullPointerException in StreamPartitionAssignor (Kafka Streams)

2016-03-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-3324: Description: KAFKA-3311 changed

[jira] [Created] (KAFKA-3324) NullPointerException in StreamPartitionAssignor (Kafka Streams)

2016-03-03 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-3324: --- Summary: NullPointerException in StreamPartitionAssignor (Kafka Streams) Key: KAFKA-3324 URL: https://issues.apache.org/jira/browse/KAFKA-3324 Project: Kafka

[jira] [Created] (KAFKA-2874) zookeeper-server-stop.sh may fail to shutdown ZK and/or may stop unrelated processes

2015-11-23 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-2874: --- Summary: zookeeper-server-stop.sh may fail to shutdown ZK and/or may stop unrelated processes Key: KAFKA-2874 URL: https://issues.apache.org/jira/browse/KAFKA-2874

[jira] [Commented] (KAFKA-2728) kafka-run-class.sh: incorrect path to tools-log4j.properties for KAFKA_LOG4J_OPTS

2015-11-04 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14989185#comment-14989185 ] Michael Noll commented on KAFKA-2728: - Rechecking the code I found that kafka-run-class.sh uses a

[jira] [Resolved] (KAFKA-2728) kafka-run-class.sh: incorrect path to tools-log4j.properties for KAFKA_LOG4J_OPTS

2015-11-04 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll resolved KAFKA-2728. - Resolution: Invalid > kafka-run-class.sh: incorrect path to tools-log4j.properties for >

[jira] [Created] (KAFKA-2740) Convert Windows bin scripts from CRLF to LF line encodings

2015-11-04 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-2740: --- Summary: Convert Windows bin scripts from CRLF to LF line encodings Key: KAFKA-2740 URL: https://issues.apache.org/jira/browse/KAFKA-2740 Project: Kafka Issue

[jira] [Updated] (KAFKA-2740) Convert Windows bin scripts from CRLF to LF line encodings

2015-11-04 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-2740: Status: Patch Available (was: Open) > Convert Windows bin scripts from CRLF to LF line encodings >

[jira] [Updated] (KAFKA-2728) kafka-run-class.sh: incorrect path to tools-log4j.properties for KAFKA_LOG4J_OPTS

2015-11-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-2728: Description: I noticed that the {{bin/kafka-run-class.sh}} and the

[jira] [Created] (KAFKA-2728) kafka-run-class.sh: incorrect path to tools-log4j.properties for KAFKA_LOG4J_OPTS

2015-11-03 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-2728: --- Summary: kafka-run-class.sh: incorrect path to tools-log4j.properties for KAFKA_LOG4J_OPTS Key: KAFKA-2728 URL: https://issues.apache.org/jira/browse/KAFKA-2728

[jira] [Updated] (KAFKA-2728) kafka-run-class.sh: incorrect path to tools-log4j.properties for KAFKA_LOG4J_OPTS

2015-11-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-2728: Description: I noticed that the {{bin/kafka-run-class.sh}} and the

[jira] [Updated] (KAFKA-2728) kafka-run-class.sh: incorrect path to tools-log4j.properties for KAFKA_LOG4J_OPTS

2015-11-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-2728: Description: I noticed that the {{bin/kafka-run-class.sh}} and the

[jira] [Updated] (KAFKA-2214) kafka-reassign-partitions.sh --verify should return non-zero exit codes when reassignment is not completed yet

2015-05-22 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-2214: Description: h4. Background The admin script {{kafka-reassign-partitions.sh}} should

[jira] [Created] (KAFKA-2214) kafka-reassign-partitions.sh --verify should return non-zero exit codes when reassignment is not completed yet

2015-05-21 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-2214: --- Summary: kafka-reassign-partitions.sh --verify should return non-zero exit codes when reassignment is not completed yet Key: KAFKA-2214 URL:

[jira] [Updated] (KAFKA-2214) kafka-reassign-partitions.sh --verify should return non-zero exit codes when reassignment is not completed yet

2015-05-21 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-2214: Description: h4. Background The admin script {{kafka-reassign-partitions.sh}} should integrate

[jira] [Created] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Michael Noll (JIRA)
Michael Noll created KAFKA-1519: --- Summary: Console consumer: expose configuration option to enable/disable writing the line separator Key: KAFKA-1519 URL: https://issues.apache.org/jira/browse/KAFKA-1519

[jira] [Updated] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-1519: Issue Type: Improvement (was: Bug) Console consumer: expose configuration option to

[jira] [Updated] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-1519: Description: The current console consumer includes a {{DefaultMessageFormatter}}, which exposes a

[jira] [Updated] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Noll updated KAFKA-1519: Description: The current console consumer includes a {{DefaultMessageFormatter}}, which exposes a

[jira] [Commented] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051615#comment-14051615 ] Michael Noll commented on KAFKA-1519: - Unfortunately, those don't work either: {code}

[jira] [Commented] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051783#comment-14051783 ] Michael Noll commented on KAFKA-1519: - Btw, for others reading this ticket: In Kafka

[jira] [Commented] (KAFKA-1519) Console consumer: expose configuration option to enable/disable writing the line separator

2014-07-03 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14051790#comment-14051790 ] Michael Noll commented on KAFKA-1519: - Supporting an empty value is of course another

[jira] [Comment Edited] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

2014-04-30 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13985617#comment-13985617 ] Michael Noll edited comment on KAFKA-1029 at 4/30/14 3:27 PM: --

[jira] [Commented] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

2014-04-30 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13985617#comment-13985617 ] Michael Noll commented on KAFKA-1029: - I could finally reproduce the bug again, though

[jira] [Comment Edited] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

2014-04-30 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13985617#comment-13985617 ] Michael Noll edited comment on KAFKA-1029 at 4/30/14 3:33 PM: --

[jira] [Commented] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

2014-04-29 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13984265#comment-13984265 ] Michael Noll commented on KAFKA-1029: - Interestingly I ran into the very same issue

[jira] [Comment Edited] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

2014-04-29 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13984265#comment-13984265 ] Michael Noll edited comment on KAFKA-1029 at 4/29/14 12:59 PM:

[jira] [Comment Edited] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

2014-04-29 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13984265#comment-13984265 ] Michael Noll edited comment on KAFKA-1029 at 4/29/14 1:12 PM: --

[jira] [Comment Edited] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

2014-04-29 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13984265#comment-13984265 ] Michael Noll edited comment on KAFKA-1029 at 4/29/14 1:22 PM: --

[jira] [Comment Edited] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

2014-04-29 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13984265#comment-13984265 ] Michael Noll edited comment on KAFKA-1029 at 4/29/14 1:27 PM: --

[jira] [Comment Edited] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

2014-04-29 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13984265#comment-13984265 ] Michael Noll edited comment on KAFKA-1029 at 4/29/14 1:30 PM: --

[jira] [Comment Edited] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

2014-04-29 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13984265#comment-13984265 ] Michael Noll edited comment on KAFKA-1029 at 4/29/14 1:35 PM: --

[jira] [Comment Edited] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

2014-04-29 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13984265#comment-13984265 ] Michael Noll edited comment on KAFKA-1029 at 4/29/14 1:35 PM: --

[jira] [Comment Edited] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

2014-04-29 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13984265#comment-13984265 ] Michael Noll edited comment on KAFKA-1029 at 4/29/14 1:36 PM: --

[jira] [Comment Edited] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

2014-04-29 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13984265#comment-13984265 ] Michael Noll edited comment on KAFKA-1029 at 4/29/14 1:45 PM: --

[jira] [Comment Edited] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

2014-04-29 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13984265#comment-13984265 ] Michael Noll edited comment on KAFKA-1029 at 4/29/14 1:45 PM: --

[jira] [Commented] (KAFKA-1380) 0.8.1.1 release candidate

2014-04-22 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13976538#comment-13976538 ] Michael Noll commented on KAFKA-1380: - Many thanks everyone for cutting this hot fix

[jira] [Commented] (KAFKA-1310) Zookeeper timeout causes deadlock in Controller

2014-03-21 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942939#comment-13942939 ] Michael Noll commented on KAFKA-1310: - I can confirm this issue, using Kafka 0.8.1.

[jira] [Commented] (KAFKA-1310) Zookeeper timeout causes deadlock in Controller

2014-03-21 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942947#comment-13942947 ] Michael Noll commented on KAFKA-1310: - Also, I can confirm the errors above do not

[jira] [Comment Edited] (KAFKA-1310) Zookeeper timeout causes deadlock in Controller

2014-03-21 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13942947#comment-13942947 ] Michael Noll edited comment on KAFKA-1310 at 3/21/14 10:23 AM:

[jira] [Commented] (KAFKA-854) Upgrade dependencies for 0.8

2014-03-20 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13941580#comment-13941580 ] Michael Noll commented on KAFKA-854: Now that one year has passed since the last update

[jira] [Commented] (KAFKA-974) can't use public release maven repo because of failure of downloaded dependency

2013-11-28 Thread Michael Noll (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13834655#comment-13834655 ] Michael Noll commented on KAFKA-974: FWIW here is an sbt snippet that resolves this