[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=16192484#comment-16192484 ] ASF GitHub Bot commented on KAFKA-6003: --- Github user asfgit closed the pull request at:

[jira] [Created] (KAFKA-6016) Use the idempotent producer in the reassign_partitions_test

Apurva Mehta created KAFKA-6016: --- Summary: Use the idempotent producer in the reassign_partitions_test Key: KAFKA-6016 URL: https://issues.apache.org/jira/browse/KAFKA-6016 Project: Kafka

[jira] [Created] (KAFKA-6015) NPE in RecordAccumulator

Apurva Mehta created KAFKA-6015: --- Summary: NPE in RecordAccumulator Key: KAFKA-6015 URL: https://issues.apache.org/jira/browse/KAFKA-6015 Project: Kafka Issue Type: Bug Affects Versions:

[jira] [Created] (KAFKA-6014) new consumer mirror maker halts after committing offsets to a deleted topic

Onur Karaman created KAFKA-6014: --- Summary: new consumer mirror maker halts after committing offsets to a deleted topic Key: KAFKA-6014 URL: https://issues.apache.org/jira/browse/KAFKA-6014 Project:

[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=16192436#comment-16192436 ] Jiri Pechanec commented on KAFKA-5953: -- I think the problem is that Connect's classloader does not

[jira] [Created] (KAFKA-6013) Controller getting stuck

Ivan Babrou created KAFKA-6013: -- Summary: Controller getting stuck Key: KAFKA-6013 URL: https://issues.apache.org/jira/browse/KAFKA-6013 Project: Kafka Issue Type: Bug Affects Versions:

[jira] [Commented] (KAFKA-3359) Parallel log-recovery of un-flushed segments on startup

[ https://issues.apache.org/jira/browse/KAFKA-3359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16192405#comment-16192405 ] Ivan Babrou commented on KAFKA-3359: It's me again. We hit the issue again and I googled into this

[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 ] Ismael Juma updated KAFKA-5829: --- Priority: Blocker (was: Critical) > Speedup broker startup after unclean shutdown by reducing

[jira] [Commented] (KAFKA-5919) Adding checks on "version" field for tools using it

[ https://issues.apache.org/jira/browse/KAFKA-5919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16192354#comment-16192354 ] Ismael Juma commented on KAFKA-5919: Nice to have, but can land in trunk only (eventual 1.1.0). >

[jira] [Updated] (KAFKA-5919) Adding checks on "version" field for tools using it

[ https://issues.apache.org/jira/browse/KAFKA-5919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5919: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Adding checks on "version" field for tools

[jira] [Commented] (KAFKA-5532) Making bootstrap.servers property a first citizen option for the ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-5532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16192353#comment-16192353 ] Ismael Juma commented on KAFKA-5532: I think this can be merged in trunk only (i.e. 1.1.0). The usable

[jira] [Updated] (KAFKA-5532) Making bootstrap.servers property a first citizen option for the ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-5532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5532: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Making bootstrap.servers property a first

[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=16192351#comment-16192351 ] Ismael Juma commented on KAFKA-5565: My suggestion is that if it doesn't land by tomorrow, we punt it.

[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=16192350#comment-16192350 ] Ismael Juma commented on KAFKA-5565: I think this one depends on [~hachikuji] having time to review

[jira] [Created] (KAFKA-6012) NoSuchElementException in markErrorMeter during TransactionsBounceTest

Ismael Juma created KAFKA-6012: -- Summary: NoSuchElementException in markErrorMeter during TransactionsBounceTest Key: KAFKA-6012 URL: https://issues.apache.org/jira/browse/KAFKA-6012 Project: Kafka

[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=16192298#comment-16192298 ] ASF GitHub Bot commented on KAFKA-5879: --- Github user asfgit closed the pull request at:

[jira] [Updated] (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:all-tabpanel ] Guozhang Wang updated KAFKA-5473: - Fix Version/s: (was: 1.0.0) 1.1.0 > handle ZK session expiration properly

[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=16192247#comment-16192247 ] Jun Rao commented on KAFKA-5473: The PR is in https://github.com/apache/kafka/pull/3990. We agreed to fix

[jira] [Commented] (KAFKA-5767) Kafka server should halt if IBP < 1.0.0 and there is log directory failure

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

[jira] [Resolved] (KAFKA-5767) Kafka server should halt if IBP < 1.0.0 and there is log directory failure

[ https://issues.apache.org/jira/browse/KAFKA-5767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-5767. Resolution: Fixed Issue resolved by pull request 3718 [https://github.com/apache/kafka/pull/3718] > Kafka

[jira] [Updated] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics

[ https://issues.apache.org/jira/browse/KAFKA-5951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Cheng updated KAFKA-5951: --- Fix Version/s: (was: 1.0.0) 1.1.0 > Autogenerate Producer RecordAccumulator

[jira] [Commented] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics

[ https://issues.apache.org/jira/browse/KAFKA-5951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16192224#comment-16192224 ] James Cheng commented on KAFKA-5951: I won't be able to address [~ijuma]'s PR feedback in time for

[jira] [Commented] (KAFKA-5848) KafkaConsumer should validate topics/TopicPartitions on subscribe/assign

[ https://issues.apache.org/jira/browse/KAFKA-5848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16192202#comment-16192202 ] Vahid Hashemian commented on KAFKA-5848: [~lijubjohn] Have you started working on this? >

[jira] [Issue Comment Deleted] (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:all-tabpanel ] Randall Hauch updated KAFKA-5953: - Comment: was deleted (was: A potential workaround is to put all of the JDBC driver JARs on the

[jira] [Updated] (KAFKA-5532) Making bootstrap.servers property a first citizen option for the ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-5532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5532: - Reviewer: Ismael Juma > Making bootstrap.servers property a first citizen option for the >

[jira] [Updated] (KAFKA-4914) Partition re-assignment tool should check types before persisting state in ZooKeeper

[ https://issues.apache.org/jira/browse/KAFKA-4914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4914: - Reviewer: Ismael Juma > Partition re-assignment tool should check types before persisting state

[jira] [Updated] (KAFKA-5919) Adding checks on "version" field for tools using it

[ https://issues.apache.org/jira/browse/KAFKA-5919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5919: - Reviewer: Ismael Juma > Adding checks on "version" field for tools using it >

[jira] [Updated] (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:all-tabpanel ] Guozhang Wang updated KAFKA-5473: - Reviewer: Ismael Juma > handle ZK session expiration properly when a new session can't be

[jira] [Updated] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91)

[ https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5886: - Reviewer: Jiangjie Qin > Introduce delivery.timeout.ms producer config (KIP-91) >

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

[ https://issues.apache.org/jira/browse/KAFKA-4307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4307: - Reviewer: Ismael Juma > Inconsistent parameters between console producer and consumer >

[jira] [Updated] (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:all-tabpanel ] Guozhang Wang updated KAFKA-5565: - Reviewer: Jason Gustafson > Add a broker metric specifying the number of consumer group

[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: Ismael Juma (was: Ewen Cheslack-Postava) > Speedup broker startup after unclean

[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

[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

[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

[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-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-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] [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=16192183#comment-16192183 ] Randall Hauch commented on KAFKA-5953: -- A potential workaround is to put all of the JDBC driver JARs

[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=16192183#comment-16192183 ] Randall Hauch edited comment on KAFKA-5953 at 10/4/17 11:07 PM: A

[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=16192178#comment-16192178 ] ASF GitHub Bot commented on KAFKA-5972: --- GitHub user shivsantham opened a pull request:

[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-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

[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] [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

[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=16192145#comment-16192145 ] Guozhang Wang commented on KAFKA-4307: -- [~ijuma] I saw you have reviewed its PR, could you update on

[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-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=16192130#comment-16192130 ] Guozhang Wang commented on KAFKA-5565: -- [~ijuma] [~hachikuji] I was not aware of KIP-180 actually,

[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=16192126#comment-16192126 ] Guozhang Wang commented on KAFKA-5473: -- [~ijuma] there seems still no PR yet. Is it a blocker for

[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=16192122#comment-16192122 ] Guozhang Wang commented on KAFKA-4201: -- Yeah it needs a KIP proposal. I'll move it post 1.0.0 release

[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

[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=16192118#comment-16192118 ] Guozhang Wang commented on KAFKA-5879: -- Any updates [~ijuma]? > Controller should read the latest

[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=16192105#comment-16192105 ] Ewen Cheslack-Postava commented on KAFKA-6011: -- [~rsivaram] Fair point, I see that we have

[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=16192081#comment-16192081 ] ASF GitHub Bot commented on KAFKA-6010: --- Github user asfgit closed the pull request at:

[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

[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 >

[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] [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=16192070#comment-16192070 ] Matthias J. Sax commented on KAFKA-5936: Don't think so. Will move to {{1.1.0}}. > KafkaProducer

[jira] [Commented] (KAFKA-6001) Remove <Bytes, byte[]> from usages of Materialized in Streams

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

[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=16192028#comment-16192028 ] ASF GitHub Bot commented on KAFKA-6003: --- GitHub user apurvam 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=16191994#comment-16191994 ] Rajini Sivaram commented on KAFKA-6011: --- The id that is passed to {{AppInfoParser}} by

[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=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=16191938#comment-16191938 ] Ismael Juma commented on KAFKA-6011: I agree that it was a mistake to use JMX directly although I

[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=16191888#comment-16191888 ] Guozhang Wang commented on KAFKA-5936: -- Is this a blocker of 1.0.0? [~hachikuji] [~mjsax] >

[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=16191880#comment-16191880 ] Guozhang Wang commented on KAFKA-5988: -- Yeah the rationale of using a static field is to avoid the

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

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

[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=16191861#comment-16191861 ] Guozhang Wang commented on KAFKA-5836: -- Which schema registry are you using Andy? Normally if a topic

[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=16191858#comment-16191858 ] ASF GitHub Bot commented on KAFKA-6010: --- GitHub user rajinisivaram opened a pull request:

[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=16191827#comment-16191827 ] ASF GitHub Bot commented on KAFKA-6008: --- Github user asfgit closed the pull request at:

[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

[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

[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=16191824#comment-16191824 ] Randall Hauch commented on KAFKA-5953: -- [~jpechane] wrote: {quote} As a result a DriverManager calls

[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

[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=16191797#comment-16191797 ] ASF GitHub Bot commented on KAFKA-5970: --- Github user asfgit closed the pull request at:

[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=16191770#comment-16191770 ] Ewen Cheslack-Postava commented on KAFKA-6008: -- Good catch, I actually don't think that

[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:

[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:

[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] [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=16191734#comment-16191734 ] ASF GitHub Bot commented on KAFKA-5990: --- Github user asfgit closed the pull request at:

[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

[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=16191726#comment-16191726 ] Damian Guy commented on KAFKA-4890: --- Yes it was fixed by KAFKA-5562 > State directory being deleted

[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

[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=16191714#comment-16191714 ] ASF GitHub Bot commented on KAFKA-4972: --- Github user asfgit closed the pull request at:

[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

[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] [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=16191615#comment-16191615 ] Guozhang Wang commented on KAFKA-4064: -- Moving it out of 1.0.0 for now. > Add support for infinite

[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

[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] [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=16191606#comment-16191606 ] Guozhang Wang commented on KAFKA-5185: -- Moving it out of 1.0.0 for now. > Adding the RecordMetadata

[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=16191605#comment-16191605 ] Guozhang Wang commented on KAFKA-5987: -- Marking it as a blocker of 1.0.0 for now. [~rhauch] please

[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

[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] [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] [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=16191597#comment-16191597 ] ASF GitHub Bot commented on KAFKA-5967: --- Github user asfgit closed the pull request at:

[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-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=16191405#comment-16191405 ] Ted Yu commented on KAFKA-5846: --- lgtm > Use singleton NoOpConsumerRebalanceListener in subscribe() call

[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=16191337#comment-16191337 ] Ismael Juma commented on KAFKA-4972: There is no thread safety issue after all. I clarified it in 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=16191324#comment-16191324 ] ASF GitHub Bot commented on KAFKA-4764: --- Github user asfgit closed the pull request at:

[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=16191321#comment-16191321 ] ASF GitHub Bot commented on KAFKA-4972: --- GitHub user ijuma opened a pull request:

  1   2   >