[jira] [Commented] (KAFKA-6000) streams 0.10.2.1 - kafka 0.11.0.1 state restore not working

[ https://issues.apache.org/jira/browse/KAFKA-6000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16190969#comment-16190969 ] Bart Vercammen commented on KAFKA-6000: --- [~yuzhih...@gmail.com] Not sure what you me

[jira] [Created] (KAFKA-6008) Kafka Connect: Unsanitized workerID causes exception during startup

Jakub Scholz created KAFKA-6008: --- Summary: Kafka Connect: Unsanitized workerID causes exception during startup Key: KAFKA-6008 URL: https://issues.apache.org/jira/browse/KAFKA-6008 Project: Kafka

[jira] [Commented] (KAFKA-6008) Kafka Connect: Unsanitized workerID causes exception during startup

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

[jira] [Commented] (KAFKA-5836) Kafka Streams - API for specifying internal stream name on join

[ https://issues.apache.org/jira/browse/KAFKA-5836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191172#comment-16191172 ] Andy Chambers commented on KAFKA-5836: -- This problem is compounded by the use of the

[jira] [Commented] (KAFKA-4764) Improve diagnostics for SASL authentication failures

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

[jira] [Commented] (KAFKA-5738) Add cumulative count attribute for all Kafka rate metrics

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

[jira] [Commented] (KAFKA-6004) Enable custom authentication plugins to return error messages to clients

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

[jira] [Updated] (KAFKA-6004) Enable custom authentication plugins to return error messages to clients

[ https://issues.apache.org/jira/browse/KAFKA-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6004: -- Fix Version/s: (was: 1.0.1) 1.0.0 > Enable custom authentication plugins

[jira] [Updated] (KAFKA-6004) Enable custom authentication plugins to return error messages to clients

[ https://issues.apache.org/jira/browse/KAFKA-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6004: -- Description: KIP-152 enables authentication failures to be returned to clients to simplify diag

[jira] [Commented] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup

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

[jira] [Commented] (KAFKA-4764) Improve diagnostics for SASL authentication failures

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

[jira] [Updated] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup

[ https://issues.apache.org/jira/browse/KAFKA-4972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4972: --- Fix Version/s: (was: 1.0.0) 1.0.1 > Kafka 0.10.0 Found a corrupted index file

[jira] [Commented] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup

[ https://issues.apache.org/jira/browse/KAFKA-4972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191337#comment-16191337 ] Ismael Juma commented on KAFKA-4972: There is no thread safety issue after all. I clar

[jira] [Updated] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup

[ https://issues.apache.org/jira/browse/KAFKA-4972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4972: --- Labels: reliability (was: ) > Kafka 0.10.0 Found a corrupted index file during Kafka broker startup

[jira] [Commented] (KAFKA-5738) Add cumulative count attribute for all Kafka rate metrics

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

[jira] [Commented] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified

[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191405#comment-16191405 ] Ted Yu commented on KAFKA-5846: --- lgtm > Use singleton NoOpConsumerRebalanceListener in subs

[jira] [Resolved] (KAFKA-5842) QueryableStateIntegrationTest may fail with JDK 7

[ https://issues.apache.org/jira/browse/KAFKA-5842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-5842. --- Resolution: Cannot Reproduce > QueryableStateIntegrationTest may fail with JDK 7 > ---

[jira] [Commented] (KAFKA-4416) Add a '--group' option to the console consumer

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

[jira] [Updated] (KAFKA-6004) Enable custom authentication plugins to return error messages to clients

[ https://issues.apache.org/jira/browse/KAFKA-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6004: -- Description: KIP-152 enables authentication failures to be returned to clients to simplify diag

[jira] [Assigned] (KAFKA-5977) Upgrade RocksDB dependency to legally acceptable version

[ https://issues.apache.org/jira/browse/KAFKA-5977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5977: Assignee: Guozhang Wang > Upgrade RocksDB dependency to legally acceptable version > --

[jira] [Commented] (KAFKA-5967) Ineffective check of negative value in CompositeReadOnlyKeyValueStore#approximateNumEntries()

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

[jira] [Updated] (KAFKA-5977) Upgrade RocksDB dependency to legally acceptable version

[ https://issues.apache.org/jira/browse/KAFKA-5977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5977: - Priority: Blocker (was: Critical) > Upgrade RocksDB dependency to legally acceptable version > --

[jira] [Updated] (KAFKA-5990) Add generated documentation for Connect metrics

[ https://issues.apache.org/jira/browse/KAFKA-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5990: - Priority: Blocker (was: Major) > Add generated documentation for Connect metrics > --

[jira] [Commented] (KAFKA-5987) Kafka metrics templates used in document generation should maintain order of tags

[ https://issues.apache.org/jira/browse/KAFKA-5987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191605#comment-16191605 ] Guozhang Wang commented on KAFKA-5987: -- Marking it as a blocker of 1.0.0 for now. [~r

[jira] [Updated] (KAFKA-5185) Adding the RecordMetadata that is returned by the producer to the commitRecord method for SourceTask

[ https://issues.apache.org/jira/browse/KAFKA-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5185: - Fix Version/s: (was: 1.0.0) > Adding the RecordMetadata that is returned by the producer to th

[jira] [Updated] (KAFKA-5987) Kafka metrics templates used in document generation should maintain order of tags

[ https://issues.apache.org/jira/browse/KAFKA-5987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5987: - Priority: Blocker (was: Major) > Kafka metrics templates used in document generation should maint

[jira] [Commented] (KAFKA-5185) Adding the RecordMetadata that is returned by the producer to the commitRecord method for SourceTask

[ https://issues.apache.org/jira/browse/KAFKA-5185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191606#comment-16191606 ] Guozhang Wang commented on KAFKA-5185: -- Moving it out of 1.0.0 for now. > Adding the

[jira] [Resolved] (KAFKA-5569) Document any changes from this task

[ https://issues.apache.org/jira/browse/KAFKA-5569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5569. Resolution: Not A Problem There is nothing to document for 1.0 release, besides KIP-161 that

[jira] [Updated] (KAFKA-5970) Deadlock due to locking of DelayedProduce and group

[ https://issues.apache.org/jira/browse/KAFKA-5970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-5970: -- Priority: Blocker (was: Critical) > Deadlock due to locking of DelayedProduce and group > -

[jira] [Updated] (KAFKA-4064) Add support for infinite endpoints for range queries in Kafka Streams KV stores

[ https://issues.apache.org/jira/browse/KAFKA-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4064: - Fix Version/s: (was: 1.0.0) > Add support for infinite endpoints for range queries in Kafka St

[jira] [Commented] (KAFKA-4064) Add support for infinite endpoints for range queries in Kafka Streams KV stores

[ https://issues.apache.org/jira/browse/KAFKA-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191615#comment-16191615 ] Guozhang Wang commented on KAFKA-4064: -- Moving it out of 1.0.0 for now. > Add suppor

[jira] [Updated] (KAFKA-6004) Enable custom authentication plugins to return error messages to clients

[ https://issues.apache.org/jira/browse/KAFKA-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-6004: -- Priority: Blocker (was: Major) > Enable custom authentication plugins to return error messages

[jira] [Resolved] (KAFKA-6004) Enable custom authentication plugins to return error messages to clients

[ https://issues.apache.org/jira/browse/KAFKA-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-6004. --- Resolution: Fixed Issue resolved by pull request 4015 [https://github.com/apache/kafka/pull/40

[jira] [Commented] (KAFKA-6004) Enable custom authentication plugins to return error messages to clients

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

[jira] [Commented] (KAFKA-4972) Kafka 0.10.0 Found a corrupted index file during Kafka broker startup

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

[jira] [Commented] (KAFKA-5856) Add AdminClient.createPartitions()

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

[jira] [Created] (KAFKA-6009) Fix formatting of autogenerated docs tables

Ewen Cheslack-Postava created KAFKA-6009: Summary: Fix formatting of autogenerated docs tables Key: KAFKA-6009 URL: https://issues.apache.org/jira/browse/KAFKA-6009 Project: Kafka Iss

[jira] [Commented] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191726#comment-16191726 ] Damian Guy commented on KAFKA-4890: --- Yes it was fixed by KAFKA-5562 > State directory b

[jira] [Resolved] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-4890. --- Resolution: Duplicate > State directory being deleted when another thread holds the lock > ---

[jira] [Resolved] (KAFKA-5990) Add generated documentation for Connect metrics

[ https://issues.apache.org/jira/browse/KAFKA-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5990. -- Resolution: Fixed Issue resolved by pull request 3987 [https://github.com/apache

[jira] [Commented] (KAFKA-5990) Add generated documentation for Connect metrics

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

[jira] [Created] (KAFKA-6010) Transient failure: MemoryRecordsBuilderTest.convertToV1WithMixedV0AndV2Data

Ismael Juma created KAFKA-6010: -- Summary: Transient failure: MemoryRecordsBuilderTest.convertToV1WithMixedV0AndV2Data Key: KAFKA-6010 URL: https://issues.apache.org/jira/browse/KAFKA-6010 Project: Kafka

[jira] [Created] (KAFKA-6011) AppInfoParser should only use metrics API and should not register JMX mbeans directly

Ewen Cheslack-Postava created KAFKA-6011: Summary: AppInfoParser should only use metrics API and should not register JMX mbeans directly Key: KAFKA-6011 URL: https://issues.apache.org/jira/browse/KAFKA-601

[jira] [Assigned] (KAFKA-6010) Transient failure: MemoryRecordsBuilderTest.convertToV1WithMixedV0AndV2Data

[ https://issues.apache.org/jira/browse/KAFKA-6010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-6010: - Assignee: Rajini Sivaram > Transient failure: MemoryRecordsBuilderTest.convertToV1WithMix

[jira] [Commented] (KAFKA-6008) Kafka Connect: Unsanitized workerID causes exception during startup

[ https://issues.apache.org/jira/browse/KAFKA-6008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191770#comment-16191770 ] Ewen Cheslack-Postava commented on KAFKA-6008: -- Good catch, I actually don't

[jira] [Commented] (KAFKA-5970) Deadlock due to locking of DelayedProduce and group

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

[jira] [Updated] (KAFKA-5987) Kafka metrics templates used in document generation should maintain order of tags

[ https://issues.apache.org/jira/browse/KAFKA-5987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-5987: - Fix Version/s: (was: 1.0.0) 1.0.1 > Kafka metrics templates used in documen

[jira] [Commented] (KAFKA-5953) Connect classloader isolation may be broken for JDBC drivers

[ https://issues.apache.org/jira/browse/KAFKA-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191824#comment-16191824 ] Randall Hauch commented on KAFKA-5953: -- [~jpechane] wrote: {quote} As a result a Dri

[jira] [Assigned] (KAFKA-6008) Kafka Connect: Unsanitized workerID causes exception during startup

[ https://issues.apache.org/jira/browse/KAFKA-6008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-6008: Assignee: Jakub Scholz > Kafka Connect: Unsanitized workerID causes excepti

[jira] [Resolved] (KAFKA-6008) Kafka Connect: Unsanitized workerID causes exception during startup

[ https://issues.apache.org/jira/browse/KAFKA-6008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6008. -- Resolution: Fixed Issue resolved by pull request 4012 [https://github.com/apache

[jira] [Commented] (KAFKA-6008) Kafka Connect: Unsanitized workerID causes exception during startup

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

[jira] [Commented] (KAFKA-6010) Transient failure: MemoryRecordsBuilderTest.convertToV1WithMixedV0AndV2Data

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

[jira] [Commented] (KAFKA-5836) Kafka Streams - API for specifying internal stream name on join

[ https://issues.apache.org/jira/browse/KAFKA-5836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191861#comment-16191861 ] Guozhang Wang commented on KAFKA-5836: -- Which schema registry are you using Andy? Nor

[jira] [Commented] (KAFKA-5889) MetricsTest is flaky

[ https://issues.apache.org/jira/browse/KAFKA-5889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191875#comment-16191875 ] Guozhang Wang commented on KAFKA-5889: -- Thanks for reporting this Ted. cc [~bbejeck]

[jira] [Commented] (KAFKA-5988) Consider removing StreamThread#STREAM_THREAD_ID_SEQUENCE

[ https://issues.apache.org/jira/browse/KAFKA-5988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191880#comment-16191880 ] Guozhang Wang commented on KAFKA-5988: -- Yeah the rationale of using a static field is

[jira] [Commented] (KAFKA-5936) KafkaProducer should not wrap InterruptedException in close() with KafkaException

[ https://issues.apache.org/jira/browse/KAFKA-5936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191888#comment-16191888 ] Guozhang Wang commented on KAFKA-5936: -- Is this a blocker of 1.0.0? [~hachikuji] [~mj

[jira] [Commented] (KAFKA-6011) AppInfoParser should only use metrics API and should not register JMX mbeans directly

[ https://issues.apache.org/jira/browse/KAFKA-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191938#comment-16191938 ] Ismael Juma commented on KAFKA-6011: I agree that it was a mistake to use JMX directly

[jira] [Commented] (KAFKA-6011) AppInfoParser should only use metrics API and should not register JMX mbeans directly

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

[jira] [Commented] (KAFKA-6011) AppInfoParser should only use metrics API and should not register JMX mbeans directly

[ https://issues.apache.org/jira/browse/KAFKA-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191994#comment-16191994 ] Rajini Sivaram commented on KAFKA-6011: --- The id that is passed to {{AppInfoParser}}

[jira] [Commented] (KAFKA-6003) Replication Fetcher thread for a partition with no data fails to start

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

[jira] [Commented] (KAFKA-6001) Remove from usages of Materialized in Streams

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

[jira] [Commented] (KAFKA-5936) KafkaProducer should not wrap InterruptedException in close() with KafkaException

[ https://issues.apache.org/jira/browse/KAFKA-5936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16192070#comment-16192070 ] Matthias J. Sax commented on KAFKA-5936: Don't think so. Will move to {{1.1.0}}.

[jira] [Updated] (KAFKA-5936) KafkaProducer should not wrap InterruptedException in close() with KafkaException

[ https://issues.apache.org/jira/browse/KAFKA-5936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5936: --- Affects Version/s: 1.0.0 > KafkaProducer should not wrap InterruptedException in close() with

[jira] [Updated] (KAFKA-5936) KafkaProducer should not wrap InterruptedException in close() with KafkaException

[ https://issues.apache.org/jira/browse/KAFKA-5936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5936: --- Fix Version/s: (was: 1.0.0) 1.0.1 1.1.0 > KafkaProdu

[jira] [Resolved] (KAFKA-6010) Transient failure: MemoryRecordsBuilderTest.convertToV1WithMixedV0AndV2Data

[ https://issues.apache.org/jira/browse/KAFKA-6010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-6010. --- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 4018 [https://git

[jira] [Commented] (KAFKA-6010) Transient failure: MemoryRecordsBuilderTest.convertToV1WithMixedV0AndV2Data

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

[jira] [Commented] (KAFKA-6011) AppInfoParser should only use metrics API and should not register JMX mbeans directly

[ https://issues.apache.org/jira/browse/KAFKA-6011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16192105#comment-16192105 ] Ewen Cheslack-Postava commented on KAFKA-6011: -- [~rsivaram] Fair point, I see

[jira] [Commented] (KAFKA-5879) Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event

[ https://issues.apache.org/jira/browse/KAFKA-5879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16192118#comment-16192118 ] Guozhang Wang commented on KAFKA-5879: -- Any updates [~ijuma]? > Controller should re

[jira] [Updated] (KAFKA-4201) Add an --assignment-strategy option to new-consumer-based Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-4201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4201: - Labels: needs-kip (was: ) > Add an --assignment-strategy option to new-consumer-based Mirror Make

[jira] [Commented] (KAFKA-4201) Add an --assignment-strategy option to new-consumer-based Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-4201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16192122#comment-16192122 ] Guozhang Wang commented on KAFKA-4201: -- Yeah it needs a KIP proposal. I'll move it po

[jira] [Updated] (KAFKA-4201) Add an --assignment-strategy option to new-consumer-based Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-4201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4201: - Fix Version/s: (was: 1.0.0) > Add an --assignment-strategy option to new-consumer-based Mirror

[jira] [Commented] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion

[ https://issues.apache.org/jira/browse/KAFKA-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16192124#comment-16192124 ] Guozhang Wang commented on KAFKA-5829: -- Updates on the reviewing progress [~hachikuji

[jira] [Commented] (KAFKA-5473) handle ZK session expiration properly when a new session can't be established

[ https://issues.apache.org/jira/browse/KAFKA-5473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16192126#comment-16192126 ] Guozhang Wang commented on KAFKA-5473: -- [~ijuma] there seems still no PR yet. Is it a

[jira] [Commented] (KAFKA-5565) Add a broker metric specifying the number of consumer group rebalances in progress

[ https://issues.apache.org/jira/browse/KAFKA-5565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16192130#comment-16192130 ] Guozhang Wang commented on KAFKA-5565: -- [~ijuma] [~hachikuji] I was not aware of KIP-

[jira] [Updated] (KAFKA-5637) Document compatibility and release policies

[ https://issues.apache.org/jira/browse/KAFKA-5637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5637: - Fix Version/s: (was: 1.0.0) > Document compatibility and release policies > --

[jira] [Commented] (KAFKA-5980) FailOnInvalidTimestamp does not log error

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

[jira] [Commented] (KAFKA-5637) Document compatibility and release policies

[ https://issues.apache.org/jira/browse/KAFKA-5637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16192138#comment-16192138 ] Guozhang Wang commented on KAFKA-5637: -- Pushing it post-1.0.0 for now. > Document co

[jira] [Commented] (KAFKA-4307) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16192145#comment-16192145 ] Guozhang Wang commented on KAFKA-4307: -- [~ijuma] I saw you have reviewed its PR, coul

[jira] [Resolved] (KAFKA-5977) Upgrade RocksDB dependency to legally acceptable version

[ https://issues.apache.org/jira/browse/KAFKA-5977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5977. -- Resolution: Duplicate Marking as duplicate of KAFKA-5576. > Upgrade RocksDB dependency to legal

[jira] [Updated] (KAFKA-5576) Support Power platform by updating rocksdb version

[ https://issues.apache.org/jira/browse/KAFKA-5576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5576: - Summary: Support Power platform by updating rocksdb version (was: Support Power platform by updat

[jira] [Updated] (KAFKA-3733) Avoid long command lines by setting CLASSPATH in environment

[ https://issues.apache.org/jira/browse/KAFKA-3733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3733: - Reviewer: Ismael Juma > Avoid long command lines by setting CLASSPATH in environment > ---

[jira] [Updated] (KAFKA-3733) Avoid long command lines by setting CLASSPATH in environment

[ https://issues.apache.org/jira/browse/KAFKA-3733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3733: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Avoid long command lines by setting CLASSPA

[jira] [Updated] (KAFKA-5637) Document compatibility and release policies

[ https://issues.apache.org/jira/browse/KAFKA-5637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5637: --- Fix Version/s: 1.1.0 > Document compatibility and release policies > -

[jira] [Updated] (KAFKA-5936) KafkaProducer should not wrap InterruptedException in close() with KafkaException

[ https://issues.apache.org/jira/browse/KAFKA-5936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5936: --- Fix Version/s: 0.11.0.2 > KafkaProducer should not wrap InterruptedException in close() with

[jira] [Commented] (KAFKA-5972) Flatten SMT does not work with null values

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

[jira] [Updated] (KAFKA-5576) Support Power platform by updating rocksdb version

[ https://issues.apache.org/jira/browse/KAFKA-5576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5576: - Priority: Blocker (was: Minor) > Support Power platform by updating rocksdb version > ---

[jira] [Updated] (KAFKA-4850) RocksDb cannot use Bloom Filters

[ https://issues.apache.org/jira/browse/KAFKA-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4850: - Fix Version/s: (was: 1.0.0) 1.1.0 > RocksDb cannot use Bloom Filters >

[jira] [Comment Edited] (KAFKA-5953) Connect classloader isolation may be broken for JDBC drivers

[ https://issues.apache.org/jira/browse/KAFKA-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16192183#comment-16192183 ] Randall Hauch edited comment on KAFKA-5953 at 10/4/17 11:07 PM:

[jira] [Commented] (KAFKA-5953) Connect classloader isolation may be broken for JDBC drivers

[ https://issues.apache.org/jira/browse/KAFKA-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16192183#comment-16192183 ] Randall Hauch commented on KAFKA-5953: -- A potential workaround is to put all of the J

[jira] [Commented] (KAFKA-4850) RocksDb cannot use Bloom Filters

[ https://issues.apache.org/jira/browse/KAFKA-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16192185#comment-16192185 ] Guozhang Wang commented on KAFKA-4850: -- Pushing it post-1.0.0 for now as it is a rath

[jira] [Updated] (KAFKA-5541) Streams should not re-throw if suspending/closing tasks fails

[ https://issues.apache.org/jira/browse/KAFKA-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5541: - Reviewer: Guozhang Wang > Streams should not re-throw if suspending/closing tasks fails >

[jira] [Updated] (KAFKA-5541) Streams should not re-throw if suspending/closing tasks fails

[ https://issues.apache.org/jira/browse/KAFKA-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5541: - Priority: Blocker (was: Major) > Streams should not re-throw if suspending/closing tasks fails >

[jira] [Updated] (KAFKA-5576) Support Power platform by updating rocksdb version

[ https://issues.apache.org/jira/browse/KAFKA-5576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5576: - Reviewer: Guozhang Wang > Support Power platform by updating rocksdb version > ---

[jira] [Updated] (KAFKA-6003) Replication Fetcher thread for a partition with no data fails to start

[ https://issues.apache.org/jira/browse/KAFKA-6003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6003: - Reviewer: Jason Gustafson > Replication Fetcher thread for a partition with no data fails to start

[jira] [Updated] (KAFKA-5904) Create Connect metrics for worker rebalances

[ https://issues.apache.org/jira/browse/KAFKA-5904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5904: - Reviewer: Ewen Cheslack-Postava > Create Connect metrics for worker rebalances > -

[jira] [Updated] (KAFKA-5989) disableLogging() causes partitions to not be consumed

[ https://issues.apache.org/jira/browse/KAFKA-5989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5989: - Reviewer: Guozhang Wang > disableLogging() causes partitions to not be consumed >

[jira] [Updated] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion

[ https://issues.apache.org/jira/browse/KAFKA-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5829: - Reviewer: Ewen Cheslack-Postava > Speedup broker startup after unclean shutdown by reducing unnece

[jira] [Updated] (KAFKA-5879) Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event

[ https://issues.apache.org/jira/browse/KAFKA-5879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5879: - Reviewer: Ismael Juma > Controller should read the latest IsrChangeNotification znodes when handli

[jira] [Updated] (KAFKA-5903) Create Connect metrics for workers

[ https://issues.apache.org/jira/browse/KAFKA-5903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5903: - Reviewer: Ewen Cheslack-Postava > Create Connect metrics for workers > ---

[jira] [Updated] (KAFKA-5829) Speedup broker startup after unclean shutdown by reducing unnecessary snapshot files deletion

[ https://issues.apache.org/jira/browse/KAFKA-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5829: - Reviewer: Jason Gustafson (was: Ismael Juma) > Speedup broker startup after unclean shutdown by r

  1   2   >