[jira] [Created] (KAFKA-6515) Add toString() method to kafka connect Field class

Bartłomiej Tartanus created KAFKA-6515: -- Summary: Add toString() method to kafka connect Field class Key: KAFKA-6515 URL: https://issues.apache.org/jira/browse/KAFKA-6515 Project: Kafka

[jira] [Comment Edited] (KAFKA-6496) NAT and Kafka

[ https://issues.apache.org/jira/browse/KAFKA-6496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348230#comment-16348230 ] hanwei edited comment on KAFKA-6496 at 2/1/18 8:57 AM: --- [~Ronald van

[jira] [Commented] (KAFKA-6505) Add simple raw "offset-commit-failures", "offset-commits" and "offset-commit-successes" count metric

[ https://issues.apache.org/jira/browse/KAFKA-6505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348232#comment-16348232 ] James Cheng commented on KAFKA-6505: [~steff1193]: Yes, a KIP is still required even i

[jira] [Commented] (KAFKA-6496) NAT and Kafka

[ https://issues.apache.org/jira/browse/KAFKA-6496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348230#comment-16348230 ] hanwei commented on KAFKA-6496: --- [~Ronald van de Kuil] Do you encounter any problem? I don't

[jira] [Commented] (KAFKA-5882) NullPointerException in StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-5882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348245#comment-16348245 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5882: --- They are not exactl

[jira] [Commented] (KAFKA-6252) A metric named 'XX' already exists, can't register another one.

[ https://issues.apache.org/jira/browse/KAFKA-6252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348345#comment-16348345 ] Gunnar Morling commented on KAFKA-6252: --- I also see this issue and can confirm it's

[jira] [Commented] (KAFKA-6498) Add RocksDB statistics via Streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348347#comment-16348347 ] james chien commented on KAFKA-6498: I have one more question is that source of stats

[jira] [Comment Edited] (KAFKA-6498) Add RocksDB statistics via Streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348347#comment-16348347 ] james chien edited comment on KAFKA-6498 at 2/1/18 10:26 AM: -

[jira] [Comment Edited] (KAFKA-6252) A metric named 'XX' already exists, can't register another one.

[ https://issues.apache.org/jira/browse/KAFKA-6252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348345#comment-16348345 ] Gunnar Morling edited comment on KAFKA-6252 at 2/1/18 10:27 AM:

[jira] [Comment Edited] (KAFKA-6252) A metric named 'XX' already exists, can't register another one.

[ https://issues.apache.org/jira/browse/KAFKA-6252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348345#comment-16348345 ] Gunnar Morling edited comment on KAFKA-6252 at 2/1/18 10:27 AM:

[jira] [Issue Comment Deleted] (KAFKA-6498) Add RocksDB statistics via Streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] james chien updated KAFKA-6498: --- Comment: was deleted (was: I have one more question is that source of stats is limited in db of kafka

[jira] [Created] (KAFKA-6516) KafkaProducer retries indefinitely to authenticate on SaslAuthenticationException

Edoardo Comar created KAFKA-6516: Summary: KafkaProducer retries indefinitely to authenticate on SaslAuthenticationException Key: KAFKA-6516 URL: https://issues.apache.org/jira/browse/KAFKA-6516 Proje

[jira] [Commented] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot

[ https://issues.apache.org/jira/browse/KAFKA-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348428#comment-16348428 ] Damian Guy commented on KAFKA-3955: --- Moving this to 1.2 > Kafka log recovery doesn't tr

[jira] [Updated] (KAFKA-3955) Kafka log recovery doesn't truncate logs on non-monotonic offsets, leading to failed broker boot

[ https://issues.apache.org/jira/browse/KAFKA-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3955: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Kafka log recovery doesn't truncate logs on n

[jira] [Commented] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large

[ https://issues.apache.org/jira/browse/KAFKA-6264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348433#comment-16348433 ] Damian Guy commented on KAFKA-6264: --- [~becket_qin]  is this a blocker for 1.1? > Log cl

[jira] [Updated] (KAFKA-1120) Controller could miss a broker state change

[ https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-1120: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Controller could miss a broker state change

[jira] [Updated] (KAFKA-1894) Avoid long or infinite blocking in the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-1894: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Avoid long or infinite blocking in the consum

[jira] [Updated] (KAFKA-2200) kafkaProducer.send() should not call callback.onCompletion()

[ https://issues.apache.org/jira/browse/KAFKA-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-2200: -- Fix Version/s: (was: 1.1.0) 1.2.0 > kafkaProducer.send() should not call callback

[jira] [Updated] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3042: -- Fix Version/s: (was: 1.1.0) 1.2.0 > updateIsr should stop after failed several ti

[jira] [Updated] (KAFKA-3143) inconsistent state in ZK when all replicas are dead

[ https://issues.apache.org/jira/browse/KAFKA-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3143: -- Fix Version/s: (was: 1.1.0) 1.2.0 > inconsistent state in ZK when all replicas ar

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

[ https://issues.apache.org/jira/browse/KAFKA-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3135: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Unexpected delay before fetch response transm

[jira] [Commented] (KAFKA-3473) KIP-237: More Controller Health Metrics

[ https://issues.apache.org/jira/browse/KAFKA-3473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348441#comment-16348441 ] Damian Guy commented on KAFKA-3473: --- [~lindong] [~ijuma] what is the status of the PR? S

[jira] [Updated] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics

[ https://issues.apache.org/jira/browse/KAFKA-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3821: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Allow Kafka Connect source tasks to produce o

[jira] [Updated] (KAFKA-3992) InstanceAlreadyExistsException Error for Consumers Starting in Parallel

[ https://issues.apache.org/jira/browse/KAFKA-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3992: -- Fix Version/s: (was: 1.1.0) 1.2.0 > InstanceAlreadyExistsException Error for Cons

[jira] [Commented] (KAFKA-6516) KafkaProducer retries indefinitely to authenticate on SaslAuthenticationException

[ https://issues.apache.org/jira/browse/KAFKA-6516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348448#comment-16348448 ] Edoardo Comar commented on KAFKA-6516: -- Please note that rather than the exception be

[jira] [Updated] (KAFKA-4133) Provide a configuration to control consumer max in-flight fetches

[ https://issues.apache.org/jira/browse/KAFKA-4133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4133: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Provide a configuration to control consumer m

[jira] [Updated] (KAFKA-4292) KIP-86: Configurable SASL callback handlers

[ https://issues.apache.org/jira/browse/KAFKA-4292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4292: -- Fix Version/s: (was: 1.1.0) > KIP-86: Configurable SASL callback handlers >

[jira] [Updated] (KAFKA-4345) Run ducktape test for each pull request

[ https://issues.apache.org/jira/browse/KAFKA-4345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4345: -- Fix Version/s: (was: 1.1.0) > Run ducktape test for each pull request >

[jira] [Updated] (KAFKA-4487) Tests should be run in Jenkins with INFO or DEBUG level

[ https://issues.apache.org/jira/browse/KAFKA-4487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4487: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Tests should be run in Jenkins with INFO or D

[jira] [Updated] (KAFKA-4668) Mirrormaker should default to auto.offset.reset=earliest

[ https://issues.apache.org/jira/browse/KAFKA-4668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4668: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Mirrormaker should default to auto.offset.res

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

[ https://issues.apache.org/jira/browse/KAFKA-4875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4875: -- Fix Version/s: (was: 1.1.0) > Kafka Streams: topic groups and builder.stream API > -

[jira] [Updated] (KAFKA-4928) Add integration test for DumpLogSegments

[ https://issues.apache.org/jira/browse/KAFKA-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4928: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Add integration test for DumpLogSegments > --

[jira] [Assigned] (KAFKA-6424) QueryableStateIntegrationTest#queryOnRebalance should accept raw text

[ https://issues.apache.org/jira/browse/KAFKA-6424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Filipe Agapito reassigned KAFKA-6424: - Assignee: Filipe Agapito > QueryableStateIntegrationTest#queryOnRebalance should accept r

[jira] [Commented] (KAFKA-6424) QueryableStateIntegrationTest#queryOnRebalance should accept raw text

[ https://issues.apache.org/jira/browse/KAFKA-6424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348460#comment-16348460 ] Filipe Agapito commented on KAFKA-6424: --- This seems like a nice newbie issue. I'm as

[jira] [Updated] (KAFKA-5023) Remove cyclic dependency between record and protocol packages

[ https://issues.apache.org/jira/browse/KAFKA-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5023: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Remove cyclic dependency between record and p

[jira] [Updated] (KAFKA-5022) Improve CRC tests so that we verify which fields are included in the CRC

[ https://issues.apache.org/jira/browse/KAFKA-5022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5022: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Improve CRC tests so that we verify which fie

[jira] [Updated] (KAFKA-5018) LogCleaner tests to verify behaviour of message format v2

[ https://issues.apache.org/jira/browse/KAFKA-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5018: -- Fix Version/s: (was: 1.1.0) 1.2.0 > LogCleaner tests to verify behaviour of messa

[jira] [Updated] (KAFKA-5026) DebuggingConsumerId and DebuggingMessageFormatter and message format v2

[ https://issues.apache.org/jira/browse/KAFKA-5026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5026: -- Fix Version/s: (was: 1.1.0) 1.2.0 > DebuggingConsumerId and DebuggingMessageForma

[jira] [Updated] (KAFKA-5025) FetchRequestTest should use batches with more than one message

[ https://issues.apache.org/jira/browse/KAFKA-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5025: -- Fix Version/s: (was: 1.1.0) 1.2.0 > FetchRequestTest should use batches with more

[jira] [Updated] (KAFKA-5092) KIP 141 - ProducerRecord Interface Improvements

[ https://issues.apache.org/jira/browse/KAFKA-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5092: -- Fix Version/s: (was: 1.1.0) 1.2.0 > KIP 141 - ProducerRecord Interface Improvemen

[jira] [Updated] (KAFKA-5030) Suggested clean-ups from message format V2 review

[ https://issues.apache.org/jira/browse/KAFKA-5030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5030: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Suggested clean-ups from message format V2 re

[jira] [Updated] (KAFKA-5041) Kafka TestKit library

[ https://issues.apache.org/jira/browse/KAFKA-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5041: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Kafka TestKit library > -

[jira] [Updated] (KAFKA-5116) Controller updates to ISR holds the controller lock for a very long time

[ https://issues.apache.org/jira/browse/KAFKA-5116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5116: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Controller updates to ISR holds the controlle

[jira] [Updated] (KAFKA-5204) Connect needs to validate Connector type during instantiation

[ https://issues.apache.org/jira/browse/KAFKA-5204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5204: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Connect needs to validate Connector type duri

[jira] [Updated] (KAFKA-5098) KafkaProducer.send() blocks and generates TimeoutException if topic name has illegal char

[ https://issues.apache.org/jira/browse/KAFKA-5098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5098: -- Fix Version/s: (was: 1.1.0) 1.2.0 > KafkaProducer.send() blocks and generates Tim

[jira] [Updated] (KAFKA-5235) GetOffsetShell: retrieve offsets for all given topics and partitions with single request to the broker

[ https://issues.apache.org/jira/browse/KAFKA-5235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5235: -- Fix Version/s: (was: 1.1.0) 1.2.0 > GetOffsetShell: retrieve offsets for all give

[jira] [Updated] (KAFKA-5255) Auto generate request/response classes

[ https://issues.apache.org/jira/browse/KAFKA-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5255: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Auto generate request/response classes >

[jira] [Updated] (KAFKA-5234) GetOffsetShell: retrieve offsets for multiple topics with single request

[ https://issues.apache.org/jira/browse/KAFKA-5234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5234: -- Fix Version/s: (was: 1.1.0) 1.2.0 > GetOffsetShell: retrieve offsets for multiple

[jira] [Updated] (KAFKA-5270) TransactionManager should send and `AddOffsetsToTxn` request only once per group per transaction

[ https://issues.apache.org/jira/browse/KAFKA-5270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5270: -- Fix Version/s: (was: 1.1.0) 1.2.0 > TransactionManager should send and `AddOffset

[jira] [Updated] (KAFKA-5286) Producer should await transaction completion in close

[ https://issues.apache.org/jira/browse/KAFKA-5286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5286: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Producer should await transaction completion

[jira] [Updated] (KAFKA-5284) Add tools and metrics to diagnose problems with the idempotent producer and transactions

[ https://issues.apache.org/jira/browse/KAFKA-5284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5284: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Add tools and metrics to diagnose problems wi

[jira] [Updated] (KAFKA-5383) Additional Test Cases for ReplicaManager

[ https://issues.apache.org/jira/browse/KAFKA-5383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5383: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Additional Test Cases for ReplicaManager > --

[jira] [Updated] (KAFKA-5347) OutOfSequence error should be fatal

[ https://issues.apache.org/jira/browse/KAFKA-5347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5347: -- Fix Version/s: (was: 1.1.0) 1.2.0 > OutOfSequence error should be fatal > ---

[jira] [Updated] (KAFKA-5356) Producer with transactionalId should be able to send outside of a transaction

[ https://issues.apache.org/jira/browse/KAFKA-5356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5356: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Producer with transactionalId should be able

[jira] [Updated] (KAFKA-5453) Controller may miss requests sent to the broker when zk session timeout happens.

[ https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5453: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Controller may miss requests sent to the brok

[jira] [Updated] (KAFKA-5451) Kafka Connect should scan classpath asynchronously

[ https://issues.apache.org/jira/browse/KAFKA-5451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5451: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Kafka Connect should scan classpath asynchron

[jira] [Updated] (KAFKA-5478) TransactionsTest.testFencingOnAddPartitions Timeout

[ https://issues.apache.org/jira/browse/KAFKA-5478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5478: -- Fix Version/s: (was: 1.1.0) 1.2.0 > TransactionsTest.testFencingOnAddPartitions T

[jira] [Updated] (KAFKA-5480) Partition Leader may not be elected although there is one live replica in ISR

[ https://issues.apache.org/jira/browse/KAFKA-5480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5480: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Partition Leader may not be elected although

[jira] [Updated] (KAFKA-5955) Transient failure: AuthorizerIntegrationTest.testTransactionalProducerTopicAuthorizationExceptionInCommit

[ https://issues.apache.org/jira/browse/KAFKA-5955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5955: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Transient failure: > AuthorizerIntegrationTe

[jira] [Updated] (KAFKA-6397) Consumer should not block setting initial positions of unavailable partitions

[ https://issues.apache.org/jira/browse/KAFKA-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6397: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Consumer should not block setting initial pos

[jira] [Updated] (KAFKA-5606) Review consumer's RequestFuture usage pattern

[ https://issues.apache.org/jira/browse/KAFKA-5606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5606: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Review consumer's RequestFuture usage pattern

[jira] [Updated] (KAFKA-3473) KIP-237: More Controller Health Metrics

[ https://issues.apache.org/jira/browse/KAFKA-3473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3473: -- Fix Version/s: (was: 1.1.0) 1.2.0 > KIP-237: More Controller Health Metrics > ---

[jira] [Updated] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4125: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Provide low-level Processor API meta data in

[jira] [Updated] (KAFKA-6489) Fetcher.retrieveOffsetsByTimes() should add all the topics to the metadata refresh topics set.

[ https://issues.apache.org/jira/browse/KAFKA-6489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6489: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Fetcher.retrieveOffsetsByTimes() should add a

[jira] [Updated] (KAFKA-6501) Add test to verify markPartitionsForTruncation after fetcher thread pool resize

[ https://issues.apache.org/jira/browse/KAFKA-6501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6501: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Add test to verify markPartitionsForTruncatio

[jira] [Updated] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large

[ https://issues.apache.org/jira/browse/KAFKA-6264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6264: -- Fix Version/s: (was: 1.0.2) (was: 1.1.0) 1.2.0 > Log clean

[jira] [Updated] (KAFKA-5950) AdminClient should retry based on returned error codes

[ https://issues.apache.org/jira/browse/KAFKA-5950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5950: -- Fix Version/s: (was: 1.1.0) 1.2.0 > AdminClient should retry based on returned er

[jira] [Updated] (KAFKA-3806) Adjust default values of log.retention.hours and offsets.retention.minutes

[ https://issues.apache.org/jira/browse/KAFKA-3806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3806: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Adjust default values of log.retention.hours

[jira] [Updated] (KAFKA-6304) The controller should allow updating the partition reassignment for the partitions being reassigned

[ https://issues.apache.org/jira/browse/KAFKA-6304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6304: -- Fix Version/s: (was: 1.1.0) 1.2.0 > The controller should allow updating the part

[jira] [Updated] (KAFKA-5729) Consumer should verify offset commits are from assigned partitions

[ https://issues.apache.org/jira/browse/KAFKA-5729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5729: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Consumer should verify offset commits are fro

[jira] [Updated] (KAFKA-6253) Improve sink connector topic regex validation

[ https://issues.apache.org/jira/browse/KAFKA-6253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6253: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Improve sink connector topic regex validation

[jira] [Updated] (KAFKA-5682) Consumer should include partition in exceptions raised during record parsing/validation

[ https://issues.apache.org/jira/browse/KAFKA-5682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5682: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Consumer should include partition in exceptio

[jira] [Updated] (KAFKA-4693) Consumer subscription change during rebalance causes exception

[ https://issues.apache.org/jira/browse/KAFKA-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4693: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Consumer subscription change during rebalance

[jira] [Updated] (KAFKA-5883) Run tests on Java 9 with –illegal-access=deny

[ https://issues.apache.org/jira/browse/KAFKA-5883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5883: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Run tests on Java 9 with –illegal-access=deny

[jira] [Updated] (KAFKA-5795) Make the idempotent producer the default producer setting

[ https://issues.apache.org/jira/browse/KAFKA-5795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5795: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Make the idempotent producer the default prod

[jira] [Updated] (KAFKA-5601) Refactor ReassignPartitionsCommand to use AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5601: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Refactor ReassignPartitionsCommand to use Adm

[jira] [Updated] (KAFKA-6438) NSEE while concurrently creating and deleting a topic

[ https://issues.apache.org/jira/browse/KAFKA-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6438: -- Fix Version/s: (was: 1.1.0) 1.2.0 > NSEE while concurrently creating and deleting

[jira] [Updated] (KAFKA-6512) Java Producer: Excessive memory usage with compression enabled

[ https://issues.apache.org/jira/browse/KAFKA-6512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6512: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Java Producer: Excessive memory usage with co

[jira] [Updated] (KAFKA-5543) We don't remove the LastStableOffsetLag metric when a partition is moved away from a broker

[ https://issues.apache.org/jira/browse/KAFKA-5543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5543: -- Fix Version/s: (was: 1.1.0) 1.2.0 > We don't remove the LastStableOffsetLag metri

[jira] [Updated] (KAFKA-6276) AdminClient may leave some futures hanging after shutdown

[ https://issues.apache.org/jira/browse/KAFKA-6276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6276: -- Fix Version/s: (was: 1.1.0) 1.2.0 > AdminClient may leave some futures hanging af

[jira] [Updated] (KAFKA-5780) Long shutdown time when updated to 0.11.0

[ https://issues.apache.org/jira/browse/KAFKA-5780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5780: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Long shutdown time when updated to 0.11.0 > -

[jira] [Updated] (KAFKA-5503) Idempotent producer ignores shutdown while fetching ProducerId

[ https://issues.apache.org/jira/browse/KAFKA-5503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5503: -- Fix Version/s: (was: 1.0.2) (was: 1.1.0) 1.2.0 > Idempoten

[jira] [Updated] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6335: -- Fix Version/s: (was: 1.1.0) 1.2.0 > SimpleAclAuthorizerTest#testHighConcurrencyMo

[jira] [Updated] (KAFKA-5907) Support aggregatedJavadoc in Java 9

[ https://issues.apache.org/jira/browse/KAFKA-5907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5907: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Support aggregatedJavadoc in Java 9 > ---

[jira] [Updated] (KAFKA-6292) KafkaConsumer ran into Unknown error fetching data for topic-partition caused by integer overflow in FileLogInputStream

[ https://issues.apache.org/jira/browse/KAFKA-6292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6292: -- Fix Version/s: (was: 1.1.0) 1.2.0 > KafkaConsumer ran into Unknown error fetching

[jira] [Updated] (KAFKA-5964) Add more unit tests for SslTransportLayer

[ https://issues.apache.org/jira/browse/KAFKA-5964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5964: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Add more unit tests for SslTransportLayer > -

[jira] [Updated] (KAFKA-6494) Extend ConfigCommand to update broker config using new AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6494: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Extend ConfigCommand to update broker config

[jira] [Updated] (KAFKA-5482) A CONCURRENT_TRANASCTIONS error for the first AddPartitionsToTxn request slows down transactions significantly

[ https://issues.apache.org/jira/browse/KAFKA-5482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5482: -- Fix Version/s: (was: 1.1.0) 1.2.0 > A CONCURRENT_TRANASCTIONS error for the first

[jira] [Updated] (KAFKA-6045) All access to log should fail if log is closed

[ https://issues.apache.org/jira/browse/KAFKA-6045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6045: -- Fix Version/s: (was: 1.1.0) 1.2.0 > All access to log should fail if log is close

[jira] [Updated] (KAFKA-5693) TopicCreationPolicy and AlterConfigsPolicy overlap

[ https://issues.apache.org/jira/browse/KAFKA-5693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5693: -- Fix Version/s: (was: 1.1.0) 1.2.0 > TopicCreationPolicy and AlterConfigsPolicy ov

[jira] [Updated] (KAFKA-5782) Avoid unnecessary PID reset when expire batches.

[ https://issues.apache.org/jira/browse/KAFKA-5782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5782: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Avoid unnecessary PID reset when expire batch

[jira] [Updated] (KAFKA-5945) Improve handling of authentication failures when credentials are removed

[ https://issues.apache.org/jira/browse/KAFKA-5945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5945: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Improve handling of authentication failures w

[jira] [Updated] (KAFKA-5736) Improve error message in Connect when all kafka brokers are down

[ https://issues.apache.org/jira/browse/KAFKA-5736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5736: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Improve error message in Connect when all kaf

[jira] [Updated] (KAFKA-5527) Idempotent/transactional Producer part 2 (KIP-98)

[ https://issues.apache.org/jira/browse/KAFKA-5527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5527: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Idempotent/transactional Producer part 2 (KIP

[jira] [Updated] (KAFKA-5661) Develop and understanding of how to tune transactions for optimal performance

[ https://issues.apache.org/jira/browse/KAFKA-5661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5661: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Develop and understanding of how to tune tran

[jira] [Updated] (KAFKA-6124) Revisit default config for internal client with regard to resilience

[ https://issues.apache.org/jira/browse/KAFKA-6124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6124: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Revisit default config for internal client wi

[jira] [Updated] (KAFKA-6029) Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest

[ https://issues.apache.org/jira/browse/KAFKA-6029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6029: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Controller should wait for the leader migrati

[jira] [Updated] (KAFKA-5857) Excessive heap usage on controller node during reassignment

[ https://issues.apache.org/jira/browse/KAFKA-5857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5857: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Excessive heap usage on controller node durin

[jira] [Updated] (KAFKA-6492) LogSemgent.truncateTo() should always resize the index file

[ https://issues.apache.org/jira/browse/KAFKA-6492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6492: -- Fix Version/s: (was: 1.1.0) 1.2.0 > LogSemgent.truncateTo() should always resize

[jira] [Updated] (KAFKA-6028) Improve the quota throttle communication.

[ https://issues.apache.org/jira/browse/KAFKA-6028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6028: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Improve the quota throttle communication. > -

  1   2   >