Bulk Operation

KAFKA-4815 Deletion of tombstones during cleaning should consider idempotent message retention

KAFKA-4815 Consumer should use last offset from batch to set next fetch offset

KAFKA-4815 UnsupportedOperationException in WriteTxnMarkers handler

KAFKA-4815 TransactionalMessageCopier should be force killed on test shutdown

KAFKA-4815 NullPointerException when loading producer snapshot

KAFKA-4815 Produce state lost if no snapshot retained

KAFKA-4815 Producer IllegalStateException: Batch has already been completed

KAFKA-4815 Transactional producer aborts batches incorrectly in abortable error state

KAFKA-4815 Transactional producer cannot find coordinator when trying to abort transaction after error

KAFKA-4815 Last Stable Offset not returned in Fetch request

KAFKA-4815 Transactions: Concurrent transactional consumer reads aborted messages

KAFKA-4815 Fix regression in compressed message iteration affecting magic v0 and v1

KAFKA-4815 Producer attempts to send transactional messages before adding partitions to transaction

KAFKA-4815 StackOverFlow error in transaction coordinator

KAFKA-4815 Broker returns messages beyond "latest stable offset" to transactional consumer in read_committed mode

KAFKA-4815 Broker clean bounce test puts the broker into a 'CONCURRENT_TRANSACTIONS' state permanently

KAFKA-4815 Add additional test cases for batch splitting to ensure idempotent/transactional metadata is preserved

KAFKA-4815 Transactions system test with hard broker bounces fails sporadically

KAFKA-4815 Resolve AddPartitions response error code inconsistency

KAFKA-4815 Update KIP-98 to reflect changes during implementation.

KAFKA-4815 TC should handle UNSUPPORTED_FOR_MESSAGE_FORMAT in WriteTxnMarker response

KAFKA-4815 Update clients and server code to make sure that epoch and sequence numbers wrap around

KAFKA-4815 Transactions integration test: Use factory methods to keep track of open producers and consumers and close them all on tearDown

KAFKA-4815 System tests for KIP-98 / transactions

KAFKA-4815 Protect concurrent access to the cached transaction status

KAFKA-4815 TransactionCoordinator must expire transactionalIds

KAFKA-4815 KafkaConsumer.committed() should get latest committed offsets from the server

KAFKA-4815 Producer only needs to send AddOffsetsToTxn one time for each group

KAFKA-4815 TransactionBounceTest occasionally fails due to partition errors

KAFKA-4815 TransactionsBounceTest occasionally sees INVALID_TXN_STATE errors

KAFKA-4815 Producer should not send AbortTxn unless transaction has actually begun

KAFKA-4815 TransactionalId authorization should imply ProducerId authorization

KAFKA-4815 Fix flaky test LogCleanerTest.testCommitMarkerRemoval

KAFKA-4815 Producer should drop queued sends when transaction is aborted

KAFKA-4815 Transaction index recovery does not snapshot properly

KAFKA-4815 Remove retention time from TxnOffsetCommit RPC

KAFKA-4815 Consumer GroupCoordinator should continue to materialize committed offsets in offset order even for transactional offset commits

KAFKA-4815 TransactinoCoordinator does not bump epoch when aborting open transactions

KAFKA-4815 Handle topic deletion for ongoing transactions

KAFKA-4815 LogCleaner should be transaction-aware

KAFKA-4815 Add Integration tests for transactional producer

KAFKA-4815 Avoid expensive initialization of producer state when upgrading

KAFKA-4815 KIP-98 : broker side handling for the TxnOffsetCommitRequest

KAFKA-4815 KafkaProducer's TransactionManager needs a review on synchronization

KAFKA-4815 Implement transaction index for KIP-98

KAFKA-4815 Load only batch header when rebuilding producer ID map

KAFKA-4815 Reconsider default retries for idempotent producer

KAFKA-4815 Think through implications of max.message.size affecting record batches in message format V2

KAFKA-4815 Additional validation in validateMessagesAndAssignOffsets

KAFKA-4815 Old clients don't support message format V2

KAFKA-4815 Update Message Delivery Semantics section to take into account KIP-98

KAFKA-4815 Update protocol documentation to mention message format v2

KAFKA-4815 Exactly-once upgrade notes

KAFKA-4815 Consider making baseOffset the first offset in message format v2

KAFKA-4815 Add request/response classes for transactions (KIP-98)

KAFKA-4815 Consider disabling record level CRC checks for message format V2

KAFKA-4815 Implement transactional clients

KAFKA-4815 Implement idempotent producer

KAFKA-4815 Message format changes for idempotent/transactional producer