KAFKA: 2.4.0 - ASF JIRA

1–200 of 242View in Issue Navigator

Key	Summary	Assignee	Status
KAFKA-8558	KIP-479 - Add StreamJoined Overload to KStream#Join	Bill Bejeck	Resolved
KAFKA-8603	Document upgrade path	A. Sophie Blee-Goldman	Resolved
KAFKA-8637	WriteBatch objects leak off-heap memory	A. Sophie Blee-Goldman	Resolved
KAFKA-8662	Produce fails if a previous produce was to an unauthorized topic	Rajini Sivaram	Resolved
KAFKA-8731	InMemorySessionStore throws NullPointerException on startup	A. Sophie Blee-Goldman	Resolved
KAFKA-8765	Remove "unstable" annotations	Matthias J. Sax	Resolved
KAFKA-8943	Move SecurityProviderCreator to a public package	Manikumar	Resolved
KAFKA-8952	Vulnerabilities found for jackson-databind-2.9.9	Ismael Juma	Resolved
KAFKA-8972	KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback state	Boyang Chen	Resolved
KAFKA-8992	Don't expose Errors in `RemoveMemberFromGroupResult`	Boyang Chen	Resolved
KAFKA-9000	Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRightThenDeleteRightEntity	John Roesler	Resolved
KAFKA-9029	Flaky Test CooperativeStickyAssignorTest.testReassignmentWithRandomSubscriptionsAndChanges	A. Sophie Blee-Goldman	Resolved
KAFKA-9032	Serializer is invoked with null when foreignValue=null	John Roesler	Resolved
KAFKA-9046	Connect worker configs require undocumented 'admin.' prefix to configure DLQ for connectors	Chris Egerton	Resolved
KAFKA-9053	AssignmentInfo#encode hardcodes the LATEST_SUPPORTED_VERSION	A. Sophie Blee-Goldman	Resolved
KAFKA-9058	Foreign Key Join should not require a queriable store	John Roesler	Resolved
KAFKA-9078	System Test Failure: ConnectRestApiTest	Konstantine Karantasis	Resolved
KAFKA-9080	System Test Failure: MessageFormatChangeTest.testCompatibilty	Tu Tran	Resolved
KAFKA-9084	AlterPartitionReassignments should not allow all replicas to be removed	Stanislav Kozlovski	Resolved
KAFKA-9133	LogCleaner thread dies with: currentLog cannot be empty on an unexpected exception	Jason Gustafson	Resolved
KAFKA-9140	Consumer gets stuck rejoining the group indefinitely	Guozhang Wang	Resolved
KAFKA-9150	DescribeGroup uses member assignment as metadata	David Jacot	Resolved
KAFKA-9156	LazyTimeIndex & LazyOffsetIndex may cause niobufferoverflow in concurrent state	Alex Mironov	Resolved
KAFKA-9175	MirrorMaker 2 emits invalid topic partition metrics	Mickael Maison	Resolved
KAFKA-9178	restoredPartitions is not cleared until the last restoring task completes	Boyang Chen	Resolved
KAFKA-9184	Redundant task creation and periodic rebalances after zombie worker rejoins the group	Konstantine Karantasis	Resolved
KAFKA-9196	Records exposed before advancement of high watermark after segment roll	Jason Gustafson	Resolved
KAFKA-9203	kafka-client 2.3.1 fails to consume lz4 compressed topic	Ismael Juma	Resolved
KAFKA-9212	Keep receiving FENCED_LEADER_EPOCH while sending ListOffsetRequest	Jason Gustafson	Resolved
KAFKA-9231	Streams Threads may die from recoverable errors with EOS enabled	John Roesler	Resolved
KAFKA-9258	Connect ConnectorStatusMetricsGroup sometimes NPE	Cyrus Vafadari	Resolved
KAFKA-5998	/.checkpoint.tmp Not found exception	John Roesler	Resolved
KAFKA-7921	Instable KafkaStreamsTest	Unassigned	Resolved
KAFKA-7937	Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup	Bob Barrett	Resolved
KAFKA-8041	Flaky Test LogDirFailureTest#testIOExceptionDuringLogRoll	Bob Barrett	Resolved
KAFKA-8086	Flaky Test GroupAuthorizerIntegrationTest#testPatternSubscriptionWithTopicAndGroupRead	Unassigned	Resolved
KAFKA-8104	Consumer cannot rejoin to the group after rebalancing	Nikolay Izhikov	Resolved
KAFKA-8602	StreamThread Dies Because Restore Consumer is not Subscribed to Any Topic	Bruno Cadonna	Resolved
KAFKA-8649	Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0	A. Sophie Blee-Goldman	Resolved
KAFKA-8671	NullPointerException occurs if topic associated with GlobalKTable changes	Alex Leung	Resolved
KAFKA-8736	Performance: ThreadCache uses size() for empty cache check	Matthew Jarvie	Resolved
KAFKA-8742	Flaky Test RepartitionWithMergeOptimizingIntegrationTest#shouldSendCorrectResults_NO_OPTIMIZATION	A. Sophie Blee-Goldman	Resolved
KAFKA-8743	Flaky Test RepartitionWithMergeOptimizingIntegrationTest#shouldSendCorrectRecords_OPTIMIZED	A. Sophie Blee-Goldman	Resolved
KAFKA-8748	Flaky Test DescribeLogDirsRequestTest#testDescribeLogDirsRequest	Ismael Juma	Resolved
KAFKA-8774	Connect REST API exposes plaintext secrets in tasks endpoint if config value contains additional characters	Arjun Satish	Resolved
KAFKA-8788	Optimize client metadata handling with a large number of partitions	Ismael Juma	Resolved
KAFKA-1714	more better bootstrapping of the gradle-wrapper.jar	Grant Henke	Resolved
KAFKA-2225	Allow fetching from ISR	Parth Brahmbhatt	Resolved
KAFKA-3333	Alternative Partitioner to Support "Always Round-Robin" partitioning	M. Manna	Resolved
KAFKA-3705	Support non-key joining in KTable	Adam Bellemare	Resolved
KAFKA-4222	Flaky Test QueryableStateIntegrationTest.queryOnRebalance	Guozhang Wang	Resolved
KAFKA-4600	Consumer proceeds on when ConsumerRebalanceListener fails	Guozhang Wang	Resolved
KAFKA-5566	Flaky Test QueryableStateIntegrationTest.shouldAllowToQueryAfterThreadDied	Matthias J. Sax	Resolved
KAFKA-6263	Expose metric for group metadata loading duration	Anastasia Vela	Resolved
KAFKA-6290	Kafka Connect cast transformation should support logical types	Nigel Liang	Resolved
KAFKA-6605	Flatten SMT does not properly handle fields that are null	Michal Borowiecki	Resolved
KAFKA-6883	KafkaShortnamer should allow to convert Kerberos principal name to upper case user name	Manikumar	Resolved
KAFKA-7018	persist memberId for consumer restart	Boyang Chen	Resolved
KAFKA-7149	Reduce assignment data size to improve kafka streams scalability	Vinoth Chandar	Resolved
KAFKA-7157	Connect TimestampConverter SMT doesn't handle null values	Valeria Vasylieva	Resolved
KAFKA-7190	Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID	Bob Barrett	Resolved
KAFKA-7197	Support Scala 2.13.0	Dejan Stojadinović	Resolved
KAFKA-7263	Container exception java.lang.IllegalStateException: Coordinator selected invalid assignment protocol: null	Unassigned	Resolved
KAFKA-7273	Converters should have access to headers.	Jeremy Custenborder	Resolved
KAFKA-7335	Store clusterId locally to ensure broker joins the right cluster	David Jacot	Resolved
KAFKA-7471	Multiple Consumer Group Management (Describe, Reset, Delete)	Alex Dunayevsky	Resolved
KAFKA-7500	MirrorMaker 2.0 (KIP-382)	Ryanne Dolan	Resolved
KAFKA-7548	KafkaConsumer should not throw away already fetched data for paused partitions.	Sean Glover	Resolved
KAFKA-7800	Extend Admin API to support dynamic application log levels	Stanislav Kozlovski	Resolved
KAFKA-7912	In-memory key-value store does not support concurrent access	A. Sophie Blee-Goldman	Resolved
KAFKA-7981	Add Replica Fetcher and Log Cleaner Count Metrics	Viktor Somogyi-Vass	Resolved
KAFKA-7990	Flaky Test KafkaStreamsTest#shouldCleanupOldStateDirs	Guozhang Wang	Resolved
KAFKA-7994	Improve Partition-Time for rebalances and restarts	Richard Yu	Resolved
KAFKA-8078	Flaky Test TableTableJoinIntegrationTest#testInnerInner	Bruno Cadonna	Resolved
KAFKA-8106	Reducing the allocation and copying of ByteBuffer when logValidator do validation.	Flower.min	Resolved
KAFKA-8122	Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState	Matthias J. Sax	Resolved
KAFKA-8146	WARNING: An illegal reflective access operation has occurred	Unassigned	Resolved
KAFKA-8179	Incremental Rebalance Protocol for Kafka Consumer	Guozhang Wang	Resolved
KAFKA-8221	Augment LeaveGroupRequest to batch operation	Boyang Chen	Resolved
KAFKA-8262	Flaky Test MetricsIntegrationTest#testStreamMetric	Bruno Cadonna	Closed
KAFKA-8263	Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore	Bruno Cadonna	Closed
KAFKA-8286	KIP-460 Admin Leader Election RPC	Jose Armando Garcia Sancio	Resolved
KAFKA-8305	AdminClient should support creating topics with default partitions and replication factor	Almog Gavra	Resolved
KAFKA-8319	Flaky Test KafkaStreamsTest.statefulTopologyShouldCreateStateDirectory	Guozhang Wang	Resolved
KAFKA-8331	Add system test for enabling static membership on KStream	Boyang Chen	Resolved
KAFKA-8333	Load high watermark checkpoint only once when handling LeaderAndIsr requests	Jason Gustafson	Resolved
KAFKA-8340	ServiceLoader fails when used from isolated plugin path directory	Greg Harris	Resolved
KAFKA-8345	Create an Administrative API for Replica Reassignment	Colin McCabe	Resolved
KAFKA-8355	Add static membership to Range assignor	Boyang Chen	Resolved
KAFKA-8390	Replace CreateDelegationToken request/response with automated protocol	Mickael Maison	Resolved
KAFKA-8392	Kafka broker leaks metric when partition leader moves to another node.	Tu Tran	Resolved
KAFKA-8400	Do not update follower replica state if the log read failed	Jason Gustafson	Resolved
KAFKA-8427	Error while cleanup under windows for EmbeddedKafkaCluster	Guozhang Wang	Resolved
KAFKA-8442	Inconsistent ISR output in topic command when using --bootstrap-server	huxihx	Resolved
KAFKA-8447	New Metric to Measure Number of Tasks on a Connector	Unassigned	Resolved
KAFKA-8448	Too many kafka.log.Log instances (Memory Leak)	Justine Olshan	Resolved
KAFKA-8452	Possible Suppress buffer optimization: de-duplicate prior value	John Roesler	Resolved
KAFKA-8456	Flaky Test StoreUpgradeIntegrationTest#shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi	Matthias J. Sax	Resolved
KAFKA-8461	Flakey test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride	Manikumar	Resolved
KAFKA-8471	Replace control requests/responses with automated protocol	Ismael Juma	Resolved
KAFKA-8487	Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit response handler	Guozhang Wang	Resolved
KAFKA-8492	Modify ConsumerCoordinator Algorithm with incremental protocol (part 2)	Guozhang Wang	Resolved
KAFKA-8493	Add PartitionsLost API in RebalanceListener (part 3)	Guozhang Wang	Resolved
KAFKA-8496	Add system test for compatibility and upgrade path (part 6)	Bill Bejeck	Resolved
KAFKA-8501	Remove key and value from exception message	Carlos Manuel Duclos Vergara	Resolved
KAFKA-8510	Update StreamsPartitionAssignor to use the built-in owned partitions to achieve stickiness (part 7)	A. Sophie Blee-Goldman	Resolved
KAFKA-8514	Kafka clients should not include Scala's Java 8 compatibility lib	Almog Gavra	Resolved
KAFKA-8523	InsertField transformation fails when encountering tombstone event	Unassigned	Resolved
KAFKA-8526	Broker may select a failed dir for new replica even in the presence of other live dirs	Igor Soarez	Resolved
KAFKA-8530	Consumer should handle authorization errors in OffsetFetch	Jason Gustafson	Resolved
KAFKA-8539	Add `group.instance.id` to Subscription class	Boyang Chen	Resolved
KAFKA-8544	Remove legacy kafka.admin.AdminClient	Ismael Juma	Resolved
KAFKA-8545	Remove legacy ZkUtils	Ismael Juma	Resolved
KAFKA-8550	Connector validation fails with aliased converters	Chris Egerton	Resolved
KAFKA-8559	PartitionStates.partitionStates cause array grow allocation.	Unassigned	Closed
KAFKA-8560	The Kafka protocol generator should support common structures	Colin McCabe	Resolved
KAFKA-8578	Add Functionality to Expose RocksDB Metrics	Bruno Cadonna	Closed
KAFKA-8579	Expose RocksDB Metrics to JMX	Bruno Cadonna	Closed
KAFKA-8580	Compute RocksDB Metrics	Bruno Cadonna	Resolved
KAFKA-8586	Source task producers silently fail to send records	Chris Egerton	Resolved
KAFKA-8594	Add Kafka Streams compatibility test for Kafka 2.3.0	Matthias J. Sax	Resolved
KAFKA-8595	Support SerDe of Decimals in JSON that are not HEX encoded	Almog Gavra	Resolved
KAFKA-8598	Replace RenewDelegationToken request/response with automated protocol	Mickael Maison	Resolved
KAFKA-8599	Replace ExpireDelegationToken request/response with automated protocol	Mickael Maison	Resolved
KAFKA-8600	Replace DescribeDelegationToken request/response with automated protocol	Viktor Somogyi-Vass	Resolved
KAFKA-8601	Producer Improvement: Sticky Partitioner	Justine Olshan	Resolved
KAFKA-8609	Add consumer metrics for rebalances (part 9)	Guozhang Wang	Resolved
KAFKA-8615	Change to track partition time breaks TimestampExtractor	A. Sophie Blee-Goldman	Resolved
KAFKA-8620	Race condition in StreamThread state change	Boyang Chen	Resolved
KAFKA-8634	Update ZooKeeper to 3.5.5	Ismael Juma	Resolved
KAFKA-8635	Unnecessary wait when looking up coordinator before transactional request	Bob Barrett	Resolved
KAFKA-8644	The Kafka protocol generator should allow null defaults for bytes and array fields	Colin McCabe	Resolved
KAFKA-8670	kafka-topics.sh shows IllegalArgumentException when describing all topics if no topics exist on the cluster	Tirtha Chatterjee	Resolved
KAFKA-8676	Avoid Stopping Unnecessary Connectors and Tasks	Unassigned	Resolved
KAFKA-8688	Upgrade system tests fail due to data loss with older message format	Rajini Sivaram	Resolved
KAFKA-8704	Add PartitionAssignor adapter for backwards compatibility	A. Sophie Blee-Goldman	Resolved
KAFKA-8717	Use cached hw/lso offset metadata when reading from log	Jason Gustafson	Resolved
KAFKA-8725	Improve LogCleaner error handling when failing to grab the filthiest log	Stanislav Kozlovski	Resolved
KAFKA-8730	Add API to delete consumer offsets (KIP-496)	David Jacot	Resolved
KAFKA-8745	DumpLogSegments doesn't show keys, when the message is null	James Cheng	Resolved
KAFKA-8755	Stand-by Task of an Optimized Source Table Does Not Write Anything to its State Store	Chris Pettitt	Resolved
KAFKA-8760	KIP-504: Add new Java Authorizer API	Rajini Sivaram	Resolved
KAFKA-8782	ReplicationQuotaManagerTest and ClientQuotaManagerTest should close Metrics object	Ismael Juma	Resolved
KAFKA-8791	RocksDBTimestampedStore should open in regular mode for new stores	Matthias J. Sax	Resolved
KAFKA-8792	Default ZK configuration to disable AdminServer	Gwen Shapira	Resolved
KAFKA-8801	electLeaderForPartitions redundancy for some success elect partitions	Unassigned	Resolved
KAFKA-8802	ConcurrentSkipListMap shows performance regression in cache and in-memory store	A. Sophie Blee-Goldman	Resolved
KAFKA-8804	Internal Connect REST endpoints are insecure	Chris Egerton	Resolved
KAFKA-8813	Race condition when creating topics and changing their configuration	Vikas Singh	Resolved
KAFKA-8816	RecordCollector offsets updated indirectly by StreamTask	Chris Pettitt	Resolved
KAFKA-8817	Flaky Test KafkaProducerTest.testCloseIsForcedOnPendingAddOffsetRequest	Guozhang Wang	Resolved
KAFKA-8819	Plugin path for converters not working as intended	Greg Harris	Resolved
KAFKA-8824	InMemoryTimeOrderedKeyValueBuffer propagates nulls when supress is configured	John Roesler	Resolved
KAFKA-8837	Several integration tests incorrectly use verifyNonDaemonThreadsStatus	Anastasia Vela	Resolved
KAFKA-8839	Improve logging in Kafka Streams around debugging task lifecycle	Vinoth Chandar	Resolved
KAFKA-8848	Update system test to use new authorizer	Rajini Sivaram	Resolved
KAFKA-8853	Create sustained connections test for Trogdor	Scott Hendricks	Resolved
KAFKA-8855	Collect and Expose Client's Name and Version in the Brokers	David Jacot	Resolved
KAFKA-8856	Add Streams Config for Backward-compatible Metrics	Bruno Cadonna	Resolved
KAFKA-8857	Config describe should not return isReadOnly=false based on synonyms	Rajini Sivaram	Resolved
KAFKA-8859	Refactor Cache-level Streams Metrics	Bruno Cadonna	Resolved
KAFKA-8860	SslPrincipalMapper should handle distinguished names with spaces	Unassigned	Resolved
KAFKA-8865	KIP-504: New Java Authorizer API	Rajini Sivaram	Resolved
KAFKA-8866	Make Authorizer create/delete exceptions Optional	Rajini Sivaram	Resolved
KAFKA-8875	CreateTopic API should check topic existence before replication factor	huxihx	Resolved
KAFKA-8878	Flaky Test AssignedStreamsTasksTest#shouldCloseCleanlyWithSuspendedTaskAndEOS	Chris Pettitt	Resolved
KAFKA-8880	Augment Consumer.committed(partition) to allow multiple partitions	Guozhang Wang	Resolved
KAFKA-8885	The Kafka Protocol should Support Optional Tagged Fields	Colin McCabe	Resolved
KAFKA-8886	Make Authorizer create/delete methods asynchronous	Rajini Sivaram	Resolved
KAFKA-8887	Use purgatory for CreateAcls and DeleteAcls if implementation is async	Rajini Sivaram	Resolved
KAFKA-8891	invalid assignment protocol java.lang.IllegalStateException: Coordinator selected invalid assignment protocol: null	Unassigned	Resolved
KAFKA-8902	Benchmark cooperative vs eager rebalancing	John Roesler	Resolved
KAFKA-8907	Return topic configs in CreateTopics response	Rajini Sivaram	Resolved
KAFKA-8911	Implicit TimeWindowedSerde creates Serde with null inner serializer	Michał	Resolved
KAFKA-8932	Add tag for TopicConfigErrorCode in CreateTopics response when KIP-482 is merged	Rajini Sivaram	Resolved
KAFKA-8934	Introduce Instance-level Metrics	Bruno Cadonna	Resolved
KAFKA-8942	Document RocksDB metrics	Bruno Cadonna	Resolved
KAFKA-8945	Incorrect null check in the constructor for ConnectorHealth and AbstractState	Chris Egerton	Resolved
KAFKA-8947	Connect framework incorrectly instantiates TaskStates for REST extensions	Chris Egerton	Resolved
KAFKA-8950	KafkaConsumer stops fetching	Unassigned	Resolved
KAFKA-8954	Topic existence check is wrongly implemented in the DeleteOffset API	David Jacot	Resolved
KAFKA-8962	KafkaAdminClient#describeTopics always goes through the controller	Unassigned	Resolved
KAFKA-8983	AdminClient deleteRecords should not fail all partitions unnecessarily	Jason Gustafson	Resolved
KAFKA-8985	Use flexibleVersions with LeaderAndIsr, UMR, etc., and improve RequestResponseTest coverage	Jason Gustafson	Resolved
KAFKA-9003	Flaky Test RepartitionOptimizingIntegrationTest#shouldSendCorrectRecords_OPTIMIZED	A. Sophie Blee-Goldman	Resolved
KAFKA-9014	AssertionError thrown by SourceRecordWriteCounter when SourceTask.poll returns an empty list	Konstantine Karantasis	Resolved
KAFKA-9020	Streams sub-topologies should be sorted by sink -> source relationship	A. Sophie Blee-Goldman	Resolved
KAFKA-9030	Document Instance-level Metrics	Bruno Cadonna	Resolved
KAFKA-9033	Change default client-id in consumer / producer to be more meaningful	Jason Gustafson	Resolved
KAFKA-9038	Allow creating partitions while partition reassignment is in progress	Unassigned	Resolved
KAFKA-9069	Flaky Test AdminClientIntegrationTest.testCreatePartitions	huxihx	Resolved
KAFKA-9072	Add Section to Streams Developer Guide for Topology Naming (KIP-307)	Bill Bejeck	Resolved
KAFKA-9073	Kafka Streams State stuck in rebalancing after one of the StreamThread encounters java.lang.IllegalStateException: No current assignment for partition	Guozhang Wang	Resolved
KAFKA-9079	System Test Failure: TransactionsTest	Jason Gustafson	Resolved
KAFKA-9089	Reassignment should be resilient to unexpected errors	Jason Gustafson	Resolved
KAFKA-9123	Add system test with large number of partitions	David Arthur	Resolved
KAFKA-9171	DelayedFetch completion may throw exception, causing successful produce to be failed	Rajini Sivaram	Resolved
KAFKA-9187	kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl	Unassigned	Reopened
KAFKA-9190	Server leaves connections with expired authentication sessions open	Ron Dagostino	Resolved
KAFKA-9198	StopReplica handler should complete pending purgatory operations	Jason Gustafson	Resolved

1–200 of 242