[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=16349884#comment-16349884 ] Manikumar commented on KAFKA-6496: -- Try configuring "advertised.listeners" config propert

[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=16349848#comment-16349848 ] Ronald van de Kuil commented on KAFKA-6496: --- I did a test with Kafka behind a ph

[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=16349848#comment-16349848 ] Ronald van de Kuil edited comment on KAFKA-6496 at 2/2/18 6:23 AM: -

[jira] [Commented] (KAFKA-6425) Calculating cleanBytes in LogToClean might not be correct

[ https://issues.apache.org/jira/browse/KAFKA-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349734#comment-16349734 ] huxihx commented on KAFKA-6425: --- Hi all, any updates for this jira? > Calculating cleanByte

[jira] [Resolved] (KAFKA-6370) MirrorMakerIntegrationTest#testCommaSeparatedRegex may fail due to NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-6370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-6370. --- Resolution: Cannot Reproduce Although it's harmless to add some defensive checks, this issue should have not

[jira] [Commented] (KAFKA-6370) MirrorMakerIntegrationTest#testCommaSeparatedRegex may fail due to NullPointerException

[ https://issues.apache.org/jira/browse/KAFKA-6370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349728#comment-16349728 ] ASF GitHub Bot commented on KAFKA-6370: --- huxihx closed pull request #4327: KAFKA-637

[jira] [Commented] (KAFKA-4739) KafkaConsumer poll going into an infinite loop

[ https://issues.apache.org/jira/browse/KAFKA-4739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349634#comment-16349634 ] Steve commented on KAFKA-4739: -- Hi,I use the Kafka Connect framework,it use the Kafka consume

[jira] [Updated] (KAFKA-6522) Retrying leaderEpoch request for partition xxx as the leader reported an error: UNKNOWN_SERVER_ERROR

[ https://issues.apache.org/jira/browse/KAFKA-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wang Shuxiao updated KAFKA-6522: Description: we have 3 brokers in a kafka cluster(brokerid:401,402,403). The broker-403 fails to fe

[jira] [Created] (KAFKA-6522) Retrying leaderEpoch request for partition xxx as the leader reported an error: UNKNOWN_SERVER_ERROR

Wang Shuxiao created KAFKA-6522: --- Summary: Retrying leaderEpoch request for partition xxx as the leader reported an error: UNKNOWN_SERVER_ERROR Key: KAFKA-6522 URL: https://issues.apache.org/jira/browse/KAFKA-6522

[jira] [Commented] (KAFKA-6362) auto commit not work since coordinatorUnknown() is always true.

[ https://issues.apache.org/jira/browse/KAFKA-6362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349616#comment-16349616 ] huxihx commented on KAFKA-6362: --- [~hachikuji] Yes, I do mean the consumer using assign() API

[jira] [Resolved] (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 ] Jason Gustafson resolved KAFKA-6492. Resolution: Fixed Assignee: Jason Gustafson Fix Version/s: (was: 1.2.0)

[jira] [Commented] (KAFKA-6388) Error while trying to roll a segment that already exists

[ https://issues.apache.org/jira/browse/KAFKA-6388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349613#comment-16349613 ] Jason Gustafson commented on KAFKA-6388: [~pdavidson] [~dhay] We have addressed on

[jira] [Commented] (KAFKA-6362) auto commit not work since coordinatorUnknown() is always true.

[ https://issues.apache.org/jira/browse/KAFKA-6362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349611#comment-16349611 ] Jason Gustafson commented on KAFKA-6362: [~huxi_2b] By "standalone," you mean a si

[jira] [Commented] (KAFKA-6362) auto commit not work since coordinatorUnknown() is always true.

[ https://issues.apache.org/jira/browse/KAFKA-6362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349609#comment-16349609 ] huxihx commented on KAFKA-6362: --- [~hachikuji] I reproduced the issue on my local test enviro

[jira] [Assigned] (KAFKA-6362) auto commit not work since coordinatorUnknown() is always true.

[ https://issues.apache.org/jira/browse/KAFKA-6362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-6362: -- Assignee: huxihx > auto commit not work since coordinatorUnknown() is always true. > --

[jira] [Commented] (KAFKA-6362) auto commit not work since coordinatorUnknown() is always true.

[ https://issues.apache.org/jira/browse/KAFKA-6362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349578#comment-16349578 ] Jason Gustafson commented on KAFKA-6362: [~RenkaiGe] Thanks for filing the issue a

[jira] [Commented] (KAFKA-6487) ChangeLoggingKeyValueBytesStore.all() returns null

[ https://issues.apache.org/jira/browse/KAFKA-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349560#comment-16349560 ] ASF GitHub Bot commented on KAFKA-6487: --- guozhangwang closed pull request #4495: KAF

[jira] [Commented] (KAFKA-6504) Connect: Some per-task-metrics not working

[ https://issues.apache.org/jira/browse/KAFKA-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349545#comment-16349545 ] ASF GitHub Bot commented on KAFKA-6504: --- rayokota opened a new pull request #4514: K

[jira] [Updated] (KAFKA-6386) Deprecate KafkaStreams constructor taking StreamsConfig parameter

[ https://issues.apache.org/jira/browse/KAFKA-6386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6386: --- Fix Version/s: 1.2.0 > Deprecate KafkaStreams constructor taking StreamsConfig parameter > ---

[jira] [Updated] (KAFKA-6058) KIP-222: Add "describe consumer groups" and "list consumer groups" to KafkaAdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Widman updated KAFKA-6058: --- Labels: kip-222 (was: needs-kip) > KIP-222: Add "describe consumer groups" and "list consumer groups"

[jira] [Commented] (KAFKA-6513) New Connect header support doesn't define `converter.type` property correctly

[ https://issues.apache.org/jira/browse/KAFKA-6513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349517#comment-16349517 ] ASF GitHub Bot commented on KAFKA-6513: --- rhauch opened a new pull request #4512: KAF

[jira] [Commented] (KAFKA-6364) Add Second Check for End Offset During Restore

[ https://issues.apache.org/jira/browse/KAFKA-6364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349456#comment-16349456 ] ASF GitHub Bot commented on KAFKA-6364: --- bbejeck opened a new pull request #4511: KA

[jira] [Created] (KAFKA-6521) Store record timestamps in KTable stores

Matthias J. Sax created KAFKA-6521: -- Summary: Store record timestamps in KTable stores Key: KAFKA-6521 URL: https://issues.apache.org/jira/browse/KAFKA-6521 Project: Kafka Issue Type: Improv

[jira] [Commented] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349439#comment-16349439 ] Andy Bryant commented on KAFKA-6378: Thanks [~guozhang] - much appreciated! > NullPoi

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16349409#comment-16349409 ] Gunnar Morling commented on KAFKA-3821: --- Thanks for the pointers, I'll give it a try

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

[ https://issues.apache.org/jira/browse/KAFKA-6515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349389#comment-16349389 ] Gunnar Morling commented on KAFKA-6515: --- Filed a PR as shown above, but can't transi

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

[ https://issues.apache.org/jira/browse/KAFKA-6515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349386#comment-16349386 ] ASF GitHub Bot commented on KAFKA-6515: --- gunnarmorling opened a new pull request #45

[jira] [Updated] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6520: --- Labels: user-experience (was: ) > When a Kafka Stream can't communicate with the server, it's

[jira] [Updated] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6520: --- Component/s: streams > When a Kafka Stream can't communicate with the server, it's Status stay

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349240#comment-16349240 ] ASF GitHub Bot commented on KAFKA-4750: --- guozhangwang closed pull request #3430: KAF

[jira] [Commented] (KAFKA-4750) KeyValueIterator returns null values

[ https://issues.apache.org/jira/browse/KAFKA-4750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349235#comment-16349235 ] ASF GitHub Bot commented on KAFKA-4750: --- guozhangwang opened a new pull request #450

[jira] [Commented] (KAFKA-6367) Fix StateRestoreListener To Use Correct Ending Offset

[ https://issues.apache.org/jira/browse/KAFKA-6367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349206#comment-16349206 ] ASF GitHub Bot commented on KAFKA-6367: --- bbejeck opened a new pull request #4507: KA

[jira] [Updated] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Kohout updated KAFKA-6520: -- Description: When you execute the following scenario the application is always in RUNNING state

[jira] [Created] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

Michael Kohout created KAFKA-6520: - Summary: When a Kafka Stream can't communicate with the server, it's Status stays RUNNING Key: KAFKA-6520 URL: https://issues.apache.org/jira/browse/KAFKA-6520 Proj

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16349179#comment-16349179 ] ASF GitHub Bot commented on KAFKA-6492: --- becketqin closed pull request #4498: KAFKA-

[jira] [Updated] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6378: - Fix Version/s: 1.2.0 1.1.0 > NullPointerException on KStream-GlobalKTable leftJ

[jira] [Commented] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349046#comment-16349046 ] Guozhang Wang commented on KAFKA-6378: -- [~kiwiandy] I have added you to the contribut

[jira] [Assigned] (KAFKA-6378) NullPointerException on KStream-GlobalKTable leftJoin when KeyValueMapper returns null

[ https://issues.apache.org/jira/browse/KAFKA-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-6378: Assignee: Andy Bryant > NullPointerException on KStream-GlobalKTable leftJoin when KeyValue

[jira] [Created] (KAFKA-6519) Change log level from ERROR to WARN for not leader for this partition exception

Antony Stubbs created KAFKA-6519: Summary: Change log level from ERROR to WARN for not leader for this partition exception Key: KAFKA-6519 URL: https://issues.apache.org/jira/browse/KAFKA-6519 Project

[jira] [Resolved] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores

[ https://issues.apache.org/jira/browse/KAFKA-6499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6499. -- Resolution: Fixed Fix Version/s: 1.2.0 1.1.0 > Avoid creating dummy ch

[jira] [Commented] (KAFKA-6499) Avoid creating dummy checkpoint files with no state stores

[ https://issues.apache.org/jira/browse/KAFKA-6499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349027#comment-16349027 ] ASF GitHub Bot commented on KAFKA-6499: --- guozhangwang closed pull request #4492: KAF

[jira] [Comment Edited] (KAFKA-6475) ConfigException on the broker results in UnknownServerException in the admin client

[ https://issues.apache.org/jira/browse/KAFKA-6475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349019#comment-16349019 ] Xavier Léauté edited comment on KAFKA-6475 at 2/1/18 6:04 PM: --

[jira] [Commented] (KAFKA-6475) ConfigException on the broker results in UnknownServerException in the admin client

[ https://issues.apache.org/jira/browse/KAFKA-6475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349019#comment-16349019 ] Xavier Léauté commented on KAFKA-6475: -- I was able to reproduce the problem by modify

[jira] [Resolved] (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 ] Jiangjie Qin resolved KAFKA-6489. - Resolution: Fixed > Fetcher.retrieveOffsetsByTimes() should add all the topics to the metadata >

[jira] [Commented] (KAFKA-6514) Add API version as a tag for the RequestsPerSec metric

[ https://issues.apache.org/jira/browse/KAFKA-6514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349012#comment-16349012 ] ASF GitHub Bot commented on KAFKA-6514: --- allenxwang opened a new pull request #4506:

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16348949#comment-16348949 ] Jiangjie Qin commented on KAFKA-6489: - [~damianguy] Can we include this in 1.1? This p

[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 ] Jiangjie Qin updated KAFKA-6489: Fix Version/s: (was: 1.2.0) 1.1.0 > Fetcher.retrieveOffsetsByTimes() should a

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16348905#comment-16348905 ] ASF GitHub Bot commented on KAFKA-6489: --- becketqin closed pull request #4478: KAFKA-

[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 ] Ewen Cheslack-Postava updated KAFKA-6253: - Fix Version/s: (was: 1.2.0) 1.1.0 > Improve sink connector

[jira] [Commented] (KAFKA-3702) SslTransportLayer.close() does not shutdown gracefully

[ https://issues.apache.org/jira/browse/KAFKA-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348894#comment-16348894 ] John Chu commented on KAFKA-3702: - Anybody have ever encountered this one? WARN: Failed to

[jira] [Updated] (KAFKA-6518) Kafka broker get stops after configured log retention time and throws I/O exception in append to log

[ https://issues.apache.org/jira/browse/KAFKA-6518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajendra Jangir updated KAFKA-6518: --- Attachment: I_O_Exception_In_Append_To_Log.png > Kafka broker get stops after configured log r

[jira] [Updated] (KAFKA-6518) Kafka broker get stops after configured log retention time and throws I/O exception in append to log

[ https://issues.apache.org/jira/browse/KAFKA-6518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajendra Jangir updated KAFKA-6518: --- Attachment: (was: AppendToLogError.PNG) > Kafka broker get stops after configured log rete

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16348685#comment-16348685 ] Randall Hauch commented on KAFKA-3821: -- See also KAFKA-6080, which allows a source co

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16348676#comment-16348676 ] Randall Hauch commented on KAFKA-3821: -- [~gunnar.morling], that'd be great. The [CON

[jira] [Created] (KAFKA-6518) Kafka broker get stops after configured log retention time and throws I/O exception in append to log

Rajendra Jangir created KAFKA-6518: -- Summary: Kafka broker get stops after configured log retention time and throws I/O exception in append to log Key: KAFKA-6518 URL: https://issues.apache.org/jira/browse/KAFKA

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

[ https://issues.apache.org/jira/browse/KAFKA-6516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar resolved KAFKA-6516. -- Resolution: Won't Fix thanks, [~rsivaram] so my expectation was invalid then > KafkaProducer re

[jira] [Created] (KAFKA-6517) ZooKeeperClient holds a lock while waiting for responses, blocking shutdown

Rajini Sivaram created KAFKA-6517: - Summary: ZooKeeperClient holds a lock while waiting for responses, blocking shutdown Key: KAFKA-6517 URL: https://issues.apache.org/jira/browse/KAFKA-6517 Project:

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16348515#comment-16348515 ] Gunnar Morling commented on KAFKA-3821: --- This is a feature which would be very helpf

[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=16348499#comment-16348499 ] Rajini Sivaram commented on KAFKA-6516: --- [~ecomar] We don't stop the sender thread i

[jira] [Updated] (KAFKA-5327) Console Consumer should only poll for up to max messages

[ https://issues.apache.org/jira/browse/KAFKA-5327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5327: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Console Consumer should only poll for up to m

[jira] [Updated] (KAFKA-5792) Transient failure in KafkaAdminClientTest.testHandleTimeout

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

[jira] [Updated] (KAFKA-6240) Support dynamic updates of frequently updated broker configs

[ https://issues.apache.org/jira/browse/KAFKA-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6240: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Support dynamic updates of frequently updated

[jira] [Updated] (KAFKA-6007) Connect can't validate against transforms in plugins.path

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

[jira] [Updated] (KAFKA-6476) Document dynamic config update

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

[jira] [Updated] (KAFKA-6452) Add documentation for delegation token authentication mechanism

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

[jira] [Updated] (KAFKA-6111) Tests for KafkaZkClient

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

[jira] [Updated] (KAFKA-5834) AbstractConfig.logUnused() may log confusing warning information.

[ https://issues.apache.org/jira/browse/KAFKA-5834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5834: -- Fix Version/s: (was: 1.1.0) 1.2.0 > AbstractConfig.logUnused() may log confusing

[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-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-5870) Idempotent producer: a producerId reset causes undesirable behavior for inflight batches to other partitions

[ https://issues.apache.org/jira/browse/KAFKA-5870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5870: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Idempotent producer: a producerId reset cause

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

[jira] [Updated] (KAFKA-6415) KafkaLog4jAppender deadlocks when logging from producer network thread

[ https://issues.apache.org/jira/browse/KAFKA-6415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6415: -- Fix Version/s: (was: 1.1.0) 1.2.0 > KafkaLog4jAppender deadlocks when logging fro

[jira] [Updated] (KAFKA-6463) Review logging level for user errors in AdminManager

[ https://issues.apache.org/jira/browse/KAFKA-6463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6463: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Review logging level for user errors in Admin

[jira] [Updated] (KAFKA-6342) Move workaround for JSON parsing of non-escaped strings

[ https://issues.apache.org/jira/browse/KAFKA-6342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-6342: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Move workaround for JSON parsing of non-escap

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

  1   2   >