[jira] [Resolved] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5065. Resolution: Fixed Fixed by KIP-266 > AbstractCoordinator.ensureCoordinatorReady() stuck

[jira] [Resolved] (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 ] Jason Gustafson resolved KAFKA-1894. Resolution: Fixed Fixed by KIP-266 (and many subsequent changes which gradually introduced

[jira] [Resolved] (KAFKA-2391) Blocking call such as position(), partitionsFor(), committed() and listTopics() should have a timeout

[ https://issues.apache.org/jira/browse/KAFKA-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2391. Resolution: Fixed Fix Version/s: 2.0.0 Fixed by KIP-266 > Blocking call such as

[jira] [Resolved] (KAFKA-4879) KafkaConsumer.position may hang forever when deleting a topic

[ https://issues.apache.org/jira/browse/KAFKA-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4879. Resolution: Fixed This is addressed by KIP-266. > KafkaConsumer.position may hang forever

[jira] [Resolved] (KAFKA-6608) Add TimeoutException to KafkaConsumer#position()

[ https://issues.apache.org/jira/browse/KAFKA-6608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6608. Resolution: Fixed Fix Version/s: 2.0.0 > Add TimeoutException to

[jira] [Resolved] (KAFKA-6916) AdminClient does not refresh metadata on broker failure

[ https://issues.apache.org/jira/browse/KAFKA-6916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6916. Resolution: Fixed > AdminClient does not refresh metadata on broker failure >

[jira] [Resolved] (KAFKA-5697) StreamThread.shutdown() need to interrupt the stream threads to break the loop

[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5697. Resolution: Fixed Fix Version/s: 2.0.0 > StreamThread.shutdown() need to interrupt

[jira] [Resolved] (KAFKA-2951) Additional authorization test cases

[ https://issues.apache.org/jira/browse/KAFKA-2951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2951. Resolution: Fixed Fix Version/s: 2.0.0 > Additional authorization test cases >

[jira] [Created] (KAFKA-6949) NoSuchElementException in ReplicaManager

Jason Gustafson created KAFKA-6949: -- Summary: NoSuchElementException in ReplicaManager Key: KAFKA-6949 URL: https://issues.apache.org/jira/browse/KAFKA-6949 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-2061) Offer a --version flag to print the kafka version

[ https://issues.apache.org/jira/browse/KAFKA-2061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2061. Resolution: Fixed Fix Version/s: 2.0.0 > Offer a --version flag to print the kafka

[jira] [Resolved] (KAFKA-6911) Incorrect check for keystore/truststore dynamic update

[ https://issues.apache.org/jira/browse/KAFKA-6911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6911. Resolution: Fixed > Incorrect check for keystore/truststore dynamic update >

[jira] [Resolved] (KAFKA-6917) Request handler deadlocks attempting to acquire group metadata lock

[ https://issues.apache.org/jira/browse/KAFKA-6917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6917. Resolution: Fixed > Request handler deadlocks attempting to acquire group metadata lock >

[jira] [Resolved] (KAFKA-6394) Prevent misconfiguration of advertised listeners

[ https://issues.apache.org/jira/browse/KAFKA-6394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6394. Resolution: Fixed Fix Version/s: 2.0.0 > Prevent misconfiguration of advertised

[jira] [Resolved] (KAFKA-6893) Processors created after acceptor started which can cause in a brief refusal to accept connections

[ https://issues.apache.org/jira/browse/KAFKA-6893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6893. Resolution: Fixed Fix Version/s: 1.1.1 > Processors created after acceptor started

[jira] [Resolved] (KAFKA-6299) Fix AdminClient error handling when metadata changes

[ https://issues.apache.org/jira/browse/KAFKA-6299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6299. Resolution: Fixed Fix Version/s: 2.0.0 > Fix AdminClient error handling when

[jira] [Resolved] (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 ] Jason Gustafson resolved KAFKA-6292. Resolution: Fixed > KafkaConsumer ran into Unknown error fetching data for topic-partition

[jira] [Created] (KAFKA-6884) ConsumerGroupCommand should use new AdminClient

Jason Gustafson created KAFKA-6884: -- Summary: ConsumerGroupCommand should use new AdminClient Key: KAFKA-6884 URL: https://issues.apache.org/jira/browse/KAFKA-6884 Project: Kafka Issue

[jira] [Created] (KAFKA-6880) Zombie replicas must be fenced

Jason Gustafson created KAFKA-6880: -- Summary: Zombie replicas must be fenced Key: KAFKA-6880 URL: https://issues.apache.org/jira/browse/KAFKA-6880 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-6879) Controller deadlock following session expiration

Jason Gustafson created KAFKA-6879: -- Summary: Controller deadlock following session expiration Key: KAFKA-6879 URL: https://issues.apache.org/jira/browse/KAFKA-6879 Project: Kafka Issue

[jira] [Resolved] (KAFKA-6867) Typos in upgrade.html

[ https://issues.apache.org/jira/browse/KAFKA-6867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6867. Resolution: Fixed > Typos in upgrade.html > - > > Key:

[jira] [Resolved] (KAFKA-6857) LeaderEpochFileCache.endOffsetFor() should check for UNDEFINED_EPOCH explicitly

[ https://issues.apache.org/jira/browse/KAFKA-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6857. Resolution: Fixed Fix Version/s: 1.1.1 1.0.2

[jira] [Resolved] (KAFKA-6854) Log cleaner fails with transaction markers that are deleted during clean

[ https://issues.apache.org/jira/browse/KAFKA-6854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6854. Resolution: Fixed > Log cleaner fails with transaction markers that are deleted during

[jira] [Resolved] (KAFKA-6810) Enable dynamic reconfiguration of SSL truststores

[ https://issues.apache.org/jira/browse/KAFKA-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6810. Resolution: Fixed > Enable dynamic reconfiguration of SSL truststores >

[jira] [Resolved] (KAFKA-6778) DescribeConfigs does not return error for non-existent topic

[ https://issues.apache.org/jira/browse/KAFKA-6778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6778. Resolution: Fixed Fix Version/s: 2.0.0 > DescribeConfigs does not return error for

[jira] [Resolved] (KAFKA-3365) Add a documentation field for types and update doc generation

[ https://issues.apache.org/jira/browse/KAFKA-3365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3365. Resolution: Fixed > Add a documentation field for types and update doc generation >

[jira] [Resolved] (KAFKA-6770) 1.1.0 New Protocol Versions section in doc is empty

[ https://issues.apache.org/jira/browse/KAFKA-6770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6770. Resolution: Fixed > 1.1.0 New Protocol Versions section in doc is empty >

[jira] [Created] (KAFKA-6796) Surprising UNKNOWN_TOPIC error for produce/fetch requests to non-replicas

Jason Gustafson created KAFKA-6796: -- Summary: Surprising UNKNOWN_TOPIC error for produce/fetch requests to non-replicas Key: KAFKA-6796 URL: https://issues.apache.org/jira/browse/KAFKA-6796 Project:

[jira] [Resolved] (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:all-tabpanel ] Jason Gustafson resolved KAFKA-6514. Resolution: Fixed Fix Version/s: 1.2.0 > Add API version as a tag for the

[jira] [Created] (KAFKA-6794) Support for incremental replica reassignment

Jason Gustafson created KAFKA-6794: -- Summary: Support for incremental replica reassignment Key: KAFKA-6794 URL: https://issues.apache.org/jira/browse/KAFKA-6794 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6781) Transient failure in KafkaAdminClientTest.testDescribeConsumerGroupOffsets

Jason Gustafson created KAFKA-6781: -- Summary: Transient failure in KafkaAdminClientTest.testDescribeConsumerGroupOffsets Key: KAFKA-6781 URL: https://issues.apache.org/jira/browse/KAFKA-6781

[jira] [Resolved] (KAFKA-6773) Kafka consumer without group.id crashes when requesting offset on a topic-partition

[ https://issues.apache.org/jira/browse/KAFKA-6773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6773. Resolution: Fixed Fix Version/s: (was: 1.1.1) (was: 1.2.0)

[jira] [Created] (KAFKA-6774) Improve default groupId behavior in consumer

Jason Gustafson created KAFKA-6774: -- Summary: Improve default groupId behavior in consumer Key: KAFKA-6774 URL: https://issues.apache.org/jira/browse/KAFKA-6774 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-6768) Producer may hang in close with pending transaction

[ https://issues.apache.org/jira/browse/KAFKA-6768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6768. Resolution: Fixed > Producer may hang in close with pending transaction >

[jira] [Created] (KAFKA-6768) Producer may hang in close with pending transaction

Jason Gustafson created KAFKA-6768: -- Summary: Producer may hang in close with pending transaction Key: KAFKA-6768 URL: https://issues.apache.org/jira/browse/KAFKA-6768 Project: Kafka Issue

[jira] [Created] (KAFKA-6751) Make max.connections.per.ip.overrides a dynamic config

Jason Gustafson created KAFKA-6751: -- Summary: Make max.connections.per.ip.overrides a dynamic config Key: KAFKA-6751 URL: https://issues.apache.org/jira/browse/KAFKA-6751 Project: Kafka

[jira] [Resolved] (KAFKA-6739) Broker receives error when handling request with java.lang.IllegalArgumentException: Magic v0 does not support record headers

[ https://issues.apache.org/jira/browse/KAFKA-6739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6739. Resolution: Fixed Fix Version/s: 1.0.2 > Broker receives error when handling request

[jira] [Resolved] (KAFKA-6724) ConsumerPerformance resets offsets on every startup

[ https://issues.apache.org/jira/browse/KAFKA-6724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6724. Resolution: Fixed Fix Version/s: 1.2.0 > ConsumerPerformance resets offsets on every

[jira] [Resolved] (KAFKA-6446) KafkaProducer with transactionId endless waits when bootstrap server is down

[ https://issues.apache.org/jira/browse/KAFKA-6446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6446. Resolution: Fixed Fix Version/s: 1.2.0 > KafkaProducer with transactionId endless

[jira] [Resolved] (KAFKA-6637) if set topic config segment.ms=0 Kafka broker won't be able to start

[ https://issues.apache.org/jira/browse/KAFKA-6637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6637. Resolution: Fixed Fix Version/s: 1.2.0 > if set topic config segment.ms=0 Kafka

[jira] [Resolved] (KAFKA-6530) Use actual first offset of messages when rolling log segment for magic v2

[ https://issues.apache.org/jira/browse/KAFKA-6530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6530. Resolution: Fixed Fix Version/s: 1.2.0 > Use actual first offset of messages when

[jira] [Resolved] (KAFKA-6672) ConfigCommand failing to alter configs

[ https://issues.apache.org/jira/browse/KAFKA-6672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6672. Resolution: Fixed Fix Version/s: 1.2.0 > ConfigCommand failing to alter configs >

[jira] [Resolved] (KAFKA-6658) Fix RoundTripWorkload and make k/v generation configurable

[ https://issues.apache.org/jira/browse/KAFKA-6658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6658. Resolution: Fixed Fix Version/s: 1.2.0 > Fix RoundTripWorkload and make k/v

[jira] [Created] (KAFKA-6672) ConfigCommand failing to alter configs

Jason Gustafson created KAFKA-6672: -- Summary: ConfigCommand failing to alter configs Key: KAFKA-6672 URL: https://issues.apache.org/jira/browse/KAFKA-6672 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-6656) Use non-zero status code when kafka-configs.sh fails

[ https://issues.apache.org/jira/browse/KAFKA-6656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6656. Resolution: Fixed Fix Version/s: 1.2.0 > Use non-zero status code when

[jira] [Resolved] (KAFKA-6653) Delayed operations may not be completed when there is lock contention

[ https://issues.apache.org/jira/browse/KAFKA-6653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6653. Resolution: Fixed Fix Version/s: 1.1.0 > Delayed operations may not be completed

[jira] [Resolved] (KAFKA-6640) Improve efficiency of KafkaAdminClient.describeTopics()

[ https://issues.apache.org/jira/browse/KAFKA-6640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6640. Resolution: Fixed Fix Version/s: 1.2.0 > Improve efficiency of

[jira] [Created] (KAFKA-6656) Use non-zero status code when kafka-configs.sh fails

Jason Gustafson created KAFKA-6656: -- Summary: Use non-zero status code when kafka-configs.sh fails Key: KAFKA-6656 URL: https://issues.apache.org/jira/browse/KAFKA-6656 Project: Kafka Issue

[jira] [Resolved] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup

[ https://issues.apache.org/jira/browse/KAFKA-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3978. Resolution: Fixed Fix Version/s: 1.2.0 > Cannot truncate to a negative offset (-1)

[jira] [Resolved] (KAFKA-6024) Consider moving validation in KafkaConsumer ahead of call to acquireAndEnsureOpen()

[ https://issues.apache.org/jira/browse/KAFKA-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6024. Resolution: Fixed Fix Version/s: 1.2.0 > Consider moving validation in KafkaConsumer

[jira] [Resolved] (KAFKA-3368) Add the Message/Record set protocol to the protocol docs

[ https://issues.apache.org/jira/browse/KAFKA-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3368. Resolution: Fixed Fix Version/s: 1.2.0 > Add the Message/Record set protocol to the

[jira] [Created] (KAFKA-6639) Follower may have sparse index if catching up

Jason Gustafson created KAFKA-6639: -- Summary: Follower may have sparse index if catching up Key: KAFKA-6639 URL: https://issues.apache.org/jira/browse/KAFKA-6639 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6635) Producer close does not await pending transaction

Jason Gustafson created KAFKA-6635: -- Summary: Producer close does not await pending transaction Key: KAFKA-6635 URL: https://issues.apache.org/jira/browse/KAFKA-6635 Project: Kafka Issue

[jira] [Resolved] (KAFKA-6622) GroupMetadataManager.loadGroupsAndOffsets decompresses record batch needlessly

[ https://issues.apache.org/jira/browse/KAFKA-6622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6622. Resolution: Fixed Fix Version/s: 1.1.0 > GroupMetadataManager.loadGroupsAndOffsets

[jira] [Created] (KAFKA-6627) Console producer default config values override explicitly provided properties

Jason Gustafson created KAFKA-6627: -- Summary: Console producer default config values override explicitly provided properties Key: KAFKA-6627 URL: https://issues.apache.org/jira/browse/KAFKA-6627

[jira] [Created] (KAFKA-6623) Consider renaming inefficient RecordBatch operations

Jason Gustafson created KAFKA-6623: -- Summary: Consider renaming inefficient RecordBatch operations Key: KAFKA-6623 URL: https://issues.apache.org/jira/browse/KAFKA-6623 Project: Kafka Issue

[jira] [Resolved] (KAFKA-6615) Add scripts for DumpLogSegments

[ https://issues.apache.org/jira/browse/KAFKA-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6615. Resolution: Fixed Fix Version/s: 1.2.0 > Add scripts for DumpLogSegments >

[jira] [Created] (KAFKA-6615) Add scripts for DumpLogSegments

Jason Gustafson created KAFKA-6615: -- Summary: Add scripts for DumpLogSegments Key: KAFKA-6615 URL: https://issues.apache.org/jira/browse/KAFKA-6615 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (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 ] Jason Gustafson resolved KAFKA-3806. Resolution: Fixed Assignee: Ewen Cheslack-Postava > Adjust default values of

[jira] [Resolved] (KAFKA-6610) initial high watermark -1, used for truncation, cause "Cannot truncate to a negative offset"

[ https://issues.apache.org/jira/browse/KAFKA-6610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6610. Resolution: Duplicate Thanks for the report. This looks like KAFKA-3978. We are still not

[jira] [Resolved] (KAFKA-6606) Regression in consumer auto-commit backoff behavior

[ https://issues.apache.org/jira/browse/KAFKA-6606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6606. Resolution: Fixed Note this issue did not affect any released version. > Regression in

[jira] [Created] (KAFKA-6609) Offset commit reordering possible on coordinator disconnect

Jason Gustafson created KAFKA-6609: -- Summary: Offset commit reordering possible on coordinator disconnect Key: KAFKA-6609 URL: https://issues.apache.org/jira/browse/KAFKA-6609 Project: Kafka

[jira] [Created] (KAFKA-6606) Regression in consumer auto-commit backoff behavior

Jason Gustafson created KAFKA-6606: -- Summary: Regression in consumer auto-commit backoff behavior Key: KAFKA-6606 URL: https://issues.apache.org/jira/browse/KAFKA-6606 Project: Kafka Issue

[jira] [Resolved] (KAFKA-3513) Transient failure of OffsetValidationTest

[ https://issues.apache.org/jira/browse/KAFKA-3513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3513. Resolution: Fixed We haven't seen this in some time, so I'm going to close this. We can

[jira] [Resolved] (KAFKA-6593) Coordinator disconnect in heartbeat thread can cause commitSync to block indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-6593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6593. Resolution: Fixed > Coordinator disconnect in heartbeat thread can cause commitSync to

[jira] [Created] (KAFKA-6593) Coordinator disconnect in heartbeat thread can cause commitSync to block indefinitely

Jason Gustafson created KAFKA-6593: -- Summary: Coordinator disconnect in heartbeat thread can cause commitSync to block indefinitely Key: KAFKA-6593 URL: https://issues.apache.org/jira/browse/KAFKA-6593

[jira] [Resolved] (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 ] Jason Gustafson resolved KAFKA-5327. Resolution: Fixed > Console Consumer should only poll for up to max messages >

[jira] [Resolved] (KAFKA-6076) Using new producer api of transaction twice failed when server run on Windows OS

[ https://issues.apache.org/jira/browse/KAFKA-6076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6076. Resolution: Duplicate Marking as dup of KAFKA-6052 since it is likely the same underlying

[jira] [Resolved] (KAFKA-6153) Kafka Transactional Messaging does not work on windows but on linux

[ https://issues.apache.org/jira/browse/KAFKA-6153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6153. Resolution: Duplicate Seems like the same underlying issue as KAFKA-6052. Marking as dup

[jira] [Resolved] (KAFKA-6196) Kafka Transactional producer with broker on windows

[ https://issues.apache.org/jira/browse/KAFKA-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6196. Resolution: Duplicate Thanks for the patch. Marking this as a dup since it seems to be the

[jira] [Resolved] (KAFKA-3744) Message format needs to identify serializer

[ https://issues.apache.org/jira/browse/KAFKA-3744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3744. Resolution: Won't Fix Closing this as "won't fix" since Kafka now supports message headers

[jira] [Created] (KAFKA-6590) Consumer bytes-fetched and records-fetched are not aggregated correctly

Jason Gustafson created KAFKA-6590: -- Summary: Consumer bytes-fetched and records-fetched are not aggregated correctly Key: KAFKA-6590 URL: https://issues.apache.org/jira/browse/KAFKA-6590 Project:

[jira] [Resolved] (KAFKA-6578) Connect distributed and standalone worker 'main()' methods should catch and log all exceptions

[ https://issues.apache.org/jira/browse/KAFKA-6578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6578. Resolution: Fixed Fix Version/s: 1.1.0 > Connect distributed and standalone worker

[jira] [Resolved] (KAFKA-6573) KafkaController.brokerInfo not updated on dynamic update

[ https://issues.apache.org/jira/browse/KAFKA-6573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6573. Resolution: Fixed > KafkaController.brokerInfo not updated on dynamic update >

[jira] [Resolved] (KAFKA-6554) Broker doesn't reject Produce request with inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-6554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6554. Resolution: Fixed Fix Version/s: 1.1.0 > Broker doesn't reject Produce request with

[jira] [Resolved] (KAFKA-5624) Unsafe use of expired sensors

[ https://issues.apache.org/jira/browse/KAFKA-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5624. Resolution: Fixed Fix Version/s: 2.0.0 > Unsafe use of expired sensors >

[jira] [Resolved] (KAFKA-6099) Seeking consumer to evicted offset resets the offset

[ https://issues.apache.org/jira/browse/KAFKA-6099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6099. Resolution: Not A Problem As pointed out by [~tomas.kralik], you should use

[jira] [Reopened] (KAFKA-6238) Issues with protocol version when applying a rolling upgrade to 1.0.0

[ https://issues.apache.org/jira/browse/KAFKA-6238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reopened KAFKA-6238: Reopening this since there is a bug in the config validation. > Issues with protocol version

[jira] [Resolved] (KAFKA-6568) LogCleanerManager.doneDeleting() should check the partition state before deleting the in progress partition

[ https://issues.apache.org/jira/browse/KAFKA-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6568. Resolution: Fixed Fix Version/s: 1.0.2 0.11.0.3 >

[jira] [Resolved] (KAFKA-5430) new consumers getting data for revoked partitions

[ https://issues.apache.org/jira/browse/KAFKA-5430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5430. Resolution: Fixed I think this issue was fixed in KAFKA-5154. Please reopen if you think it

[jira] [Resolved] (KAFKA-6541) StackOverflow exceptions in thread 'kafka-coordinator-heartbeat-thread

[ https://issues.apache.org/jira/browse/KAFKA-6541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6541. Resolution: Duplicate Closing as duplicate for now. Please reopen if you think the issue

[jira] [Resolved] (KAFKA-5996) JsonConverter generates "Mismatching schema" DataException

[ https://issues.apache.org/jira/browse/KAFKA-5996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5996. Resolution: Fixed Fix Version/s: 1.0.2 1.1.0 > JsonConverter

[jira] [Resolved] (KAFKA-4221) KafkaConsumer Fetcher can send ListOffsets requests in parallel when initializing position

[ https://issues.apache.org/jira/browse/KAFKA-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4221. Resolution: Duplicate > KafkaConsumer Fetcher can send ListOffsets requests in parallel

[jira] [Reopened] (KAFKA-4221) KafkaConsumer Fetcher can send ListOffsets requests in parallel when initializing position

[ https://issues.apache.org/jira/browse/KAFKA-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reopened KAFKA-4221: > KafkaConsumer Fetcher can send ListOffsets requests in parallel when > initializing position

[jira] [Resolved] (KAFKA-4221) KafkaConsumer Fetcher can send ListOffsets requests in parallel when initializing position

[ https://issues.apache.org/jira/browse/KAFKA-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4221. Resolution: Fixed > KafkaConsumer Fetcher can send ListOffsets requests in parallel when >

[jira] [Resolved] (KAFKA-6511) Connect header parser incorrectly parses arrays

[ https://issues.apache.org/jira/browse/KAFKA-6511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6511. Resolution: Fixed > Connect header parser incorrectly parses arrays >

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

[jira] [Resolved] (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 resolved KAFKA-6362. Resolution: Fixed Fix Version/s: 1.1.0 > auto commit not work since

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

[ https://issues.apache.org/jira/browse/KAFKA-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6504. Resolution: Fixed Fix Version/s: 1.1.0 > Connect: Some per-task-metrics not working

[jira] [Created] (KAFKA-6540) Consumer lag metric is not updated when a partition is paused

Jason Gustafson created KAFKA-6540: -- Summary: Consumer lag metric is not updated when a partition is paused Key: KAFKA-6540 URL: https://issues.apache.org/jira/browse/KAFKA-6540 Project: Kafka

[jira] [Resolved] (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:all-tabpanel ] Jason Gustafson resolved KAFKA-6515. Resolution: Fixed Fix Version/s: 1.2.0 > Add toString() method to kafka connect

[jira] [Created] (KAFKA-6530) Use actual first offset of messages when rolling log segment for magic v2

Jason Gustafson created KAFKA-6530: -- Summary: Use actual first offset of messages when rolling log segment for magic v2 Key: KAFKA-6530 URL: https://issues.apache.org/jira/browse/KAFKA-6530 Project:

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

[jira] [Created] (KAFKA-6528) Transient failure in DynamicBrokerReconfigurationTest.testThreadPoolResize

Jason Gustafson created KAFKA-6528: -- Summary: Transient failure in DynamicBrokerReconfigurationTest.testThreadPoolResize Key: KAFKA-6528 URL: https://issues.apache.org/jira/browse/KAFKA-6528

[jira] [Created] (KAFKA-6527) Transient failure in DynamicBrokerReconfigurationTest.testDefaultTopicConfig

Jason Gustafson created KAFKA-6527: -- Summary: Transient failure in DynamicBrokerReconfigurationTest.testDefaultTopicConfig Key: KAFKA-6527 URL: https://issues.apache.org/jira/browse/KAFKA-6527

[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] [Resolved] (KAFKA-6418) AdminClient should handle empty or null topic names better

[ https://issues.apache.org/jira/browse/KAFKA-6418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6418. Resolution: Fixed Fix Version/s: 1.1.0 > AdminClient should handle empty or null

[jira] [Resolved] (KAFKA-6467) Enforce layout of dependencies within a Connect plugin to be deterministic

[ https://issues.apache.org/jira/browse/KAFKA-6467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6467. Resolution: Fixed Reviewer: Jason Gustafson (was: Ewen Cheslack-Postava) > Enforce

[jira] [Resolved] (KAFKA-4991) KerberosLogin#login should probably be synchronized

[ https://issues.apache.org/jira/browse/KAFKA-4991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4991. Resolution: Fixed Assignee: Manikumar (was: Colin P. McCabe) > KerberosLogin#login

[jira] [Resolved] (KAFKA-4897) LogCleaner#cleanSegments should not ignore failures to delete files

[ https://issues.apache.org/jira/browse/KAFKA-4897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4897. Resolution: Fixed > LogCleaner#cleanSegments should not ignore failures to delete files >

[jira] [Resolved] (KAFKA-6429) dirtyNonActiveSegments in `cleanableOffsets` should only be created when log.cleaner.min.compaction.lag.ms > 0

[ https://issues.apache.org/jira/browse/KAFKA-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6429. Resolution: Fixed > dirtyNonActiveSegments in `cleanableOffsets` should only be created

<    4   5   6   7   8   9   10   11   12   13   >