|
kafka git commit: KAFKA-5350: Modify unstable annotations in Streams API |
|
| guozh...@apache.org |
kafka git commit: KAFKA-5350: Modify unstable annotations in Streams API |
Thu, 01 Jun, 02:30 |
| guozh...@apache.org |
kafka git commit: KAFKA-5350: Modify unstable annotations in Streams API |
Thu, 01 Jun, 02:30 |
|
kafka git commit: KAFKA-5226; Fixes issue where adding topics matching a regex |
|
| guozh...@apache.org |
kafka git commit: KAFKA-5226; Fixes issue where adding topics matching a regex |
Thu, 01 Jun, 02:36 |
| guozh...@apache.org |
kafka git commit: KAFKA-5226; Fixes issue where adding topics matching a regex |
Thu, 01 Jun, 02:36 |
|
kafka git commit: KAFKA-5340; Batch splitting should preserve magic and transactional flag |
|
| j...@apache.org |
kafka git commit: KAFKA-5340; Batch splitting should preserve magic and transactional flag |
Thu, 01 Jun, 04:33 |
| j...@apache.org |
kafka git commit: KAFKA-5340; Batch splitting should preserve magic and transactional flag |
Thu, 01 Jun, 04:34 |
|
kafka git commit: KAFKA-5351: Reset pending state when returning an error in appendTransactionToLog |
|
| guozh...@apache.org |
kafka git commit: KAFKA-5351: Reset pending state when returning an error in appendTransactionToLog |
Thu, 01 Jun, 05:48 |
| guozh...@apache.org |
kafka git commit: KAFKA-5351: Reset pending state when returning an error in appendTransactionToLog |
Thu, 01 Jun, 05:48 |
|
kafka git commit: MINOR: Traverse plugin path recursively in Connect (KIP-146) |
|
| ewe...@apache.org |
kafka git commit: MINOR: Traverse plugin path recursively in Connect (KIP-146) |
Thu, 01 Jun, 09:08 |
| ewe...@apache.org |
kafka git commit: MINOR: Traverse plugin path recursively in Connect (KIP-146) |
Thu, 01 Jun, 09:08 |
| ij...@apache.org |
kafka git commit: KAFKA-5316; LogCleaner should account for larger record sets after cleaning |
Thu, 01 Jun, 10:02 |
|
kafka git commit: KAFKA-4956: Verify client-side throttle time metrics in quota test |
|
| rsiva...@apache.org |
kafka git commit: KAFKA-4956: Verify client-side throttle time metrics in quota test |
Thu, 01 Jun, 14:45 |
| rsiva...@apache.org |
kafka git commit: KAFKA-4956: Verify client-side throttle time metrics in quota test |
Thu, 01 Jun, 14:46 |
|
kafka git commit: KAFKA-4459: Run rat checks in Jenkins script |
|
| ewe...@apache.org |
kafka git commit: KAFKA-4459: Run rat checks in Jenkins script |
Thu, 01 Jun, 16:33 |
| ewe...@apache.org |
kafka git commit: KAFKA-4459: Run rat checks in Jenkins script |
Thu, 01 Jun, 16:33 |
|
kafka git commit: KAFKA-5360; Down-converted uncompressed batches should respect fetch offset |
|
| j...@apache.org |
kafka git commit: KAFKA-5360; Down-converted uncompressed batches should respect fetch offset |
Thu, 01 Jun, 17:19 |
| j...@apache.org |
kafka git commit: KAFKA-5360; Down-converted uncompressed batches should respect fetch offset |
Thu, 01 Jun, 17:19 |
|
kafka git commit: KAFKA-5281; System tests for transactions |
|
| j...@apache.org |
kafka git commit: KAFKA-5281; System tests for transactions |
Thu, 01 Jun, 17:26 |
| j...@apache.org |
kafka git commit: KAFKA-5281; System tests for transactions |
Thu, 01 Jun, 17:27 |
| ij...@apache.org |
kafka git commit: KAFKA-5150; reduce lz4 decompression overhead |
Thu, 01 Jun, 19:05 |
|
kafka git commit: KAFKA-5361: Add EOS integration tests for Streams API |
|
| guozh...@apache.org |
kafka git commit: KAFKA-5361: Add EOS integration tests for Streams API |
Thu, 01 Jun, 20:16 |
| guozh...@apache.org |
kafka git commit: KAFKA-5361: Add EOS integration tests for Streams API |
Thu, 01 Jun, 20:17 |
|
kafka git commit: KAFKA-5293; Do not apply exponential backoff if users have overridden… |
|
| ij...@apache.org |
kafka git commit: KAFKA-5293; Do not apply exponential backoff if users have overridden… |
Thu, 01 Jun, 20:27 |
| ij...@apache.org |
kafka git commit: KAFKA-5293; Do not apply exponential backoff if users have overridden… |
Thu, 01 Jun, 20:28 |
|
[1/2] kafka git commit: KAFKA-5154: do not set rejoinNeeded in joinGroup response but in syncGroup response handler |
|
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-5154: do not set rejoinNeeded in joinGroup response but in syncGroup response handler |
Thu, 01 Jun, 20:31 |
| guozh...@apache.org |
[2/2] kafka git commit: set the rejoinNeeded in listener's onSuccess |
Thu, 01 Jun, 20:31 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-5154: do not set rejoinNeeded in joinGroup response but in syncGroup response handler |
Thu, 01 Jun, 20:33 |
| guozh...@apache.org |
[2/2] kafka git commit: set the rejoinNeeded in listener's onSuccess |
Thu, 01 Jun, 20:33 |
|
kafka git commit: MINOR: add upgrade not for group.initial.rebalance.delay.ms |
|
| guozh...@apache.org |
kafka git commit: MINOR: add upgrade not for group.initial.rebalance.delay.ms |
Thu, 01 Jun, 20:42 |
| guozh...@apache.org |
kafka git commit: MINOR: add upgrade not for group.initial.rebalance.delay.ms |
Thu, 01 Jun, 20:42 |
|
kafka git commit: KAFKA-5229: Reflections logs excessive warnings when scanning classpaths |
|
| ewe...@apache.org |
kafka git commit: KAFKA-5229: Reflections logs excessive warnings when scanning classpaths |
Thu, 01 Jun, 20:47 |
| ewe...@apache.org |
kafka git commit: KAFKA-5229: Reflections logs excessive warnings when scanning classpaths |
Thu, 01 Jun, 20:47 |
|
kafka git commit: KAFKA-5345; Close KafkaClient when streams client is closed |
|
| ij...@apache.org |
kafka git commit: KAFKA-5345; Close KafkaClient when streams client is closed |
Thu, 01 Jun, 20:54 |
| ij...@apache.org |
kafka git commit: KAFKA-5345; Close KafkaClient when streams client is closed |
Thu, 01 Jun, 20:54 |
| rsiva...@apache.org |
kafka git commit: KAFKA-5345; Close KafkaClient when streams client is closed |
Fri, 02 Jun, 14:43 |
|
kafka git commit: MINOR: update Streams docs for KIP-123 |
|
| guozh...@apache.org |
kafka git commit: MINOR: update Streams docs for KIP-123 |
Thu, 01 Jun, 22:27 |
| guozh...@apache.org |
kafka git commit: MINOR: update Streams docs for KIP-123 |
Thu, 01 Jun, 22:27 |
| guozh...@apache.org |
[1/3] kafka-site git commit: Add auto syntax highlighter |
Thu, 01 Jun, 23:24 |
| guozh...@apache.org |
[2/3] kafka-site git commit: Add auto syntax highlighter |
Thu, 01 Jun, 23:24 |
| guozh...@apache.org |
[3/3] kafka-site git commit: Add auto syntax highlighter |
Thu, 01 Jun, 23:24 |
| guozh...@apache.org |
kafka-site git commit: Filled in og meta tags |
Thu, 01 Jun, 23:25 |
|
kafka git commit: MINOR: Add upgrade notes for KAFKA-2358 |
|
| guozh...@apache.org |
kafka git commit: MINOR: Add upgrade notes for KAFKA-2358 |
Fri, 02 Jun, 01:24 |
| guozh...@apache.org |
kafka git commit: MINOR: Add upgrade notes for KAFKA-2358 |
Fri, 02 Jun, 01:25 |
|
kafka git commit: MINOR: Logging/debugging improvements for transactions |
|
| j...@apache.org |
kafka git commit: MINOR: Logging/debugging improvements for transactions |
Fri, 02 Jun, 02:08 |
| j...@apache.org |
kafka git commit: MINOR: Logging/debugging improvements for transactions |
Fri, 02 Jun, 02:09 |
|
[1/2] kafka git commit: KAFKA-5283; Handle producer epoch/sequence overflow |
|
| j...@apache.org |
[1/2] kafka git commit: KAFKA-5283; Handle producer epoch/sequence overflow |
Fri, 02 Jun, 06:41 |
| j...@apache.org |
[2/2] kafka git commit: KAFKA-5283; Handle producer epoch/sequence overflow |
Fri, 02 Jun, 06:41 |
| j...@apache.org |
[1/2] kafka git commit: KAFKA-5283; Handle producer epoch/sequence overflow |
Fri, 02 Jun, 06:41 |
| j...@apache.org |
[2/2] kafka git commit: KAFKA-5283; Handle producer epoch/sequence overflow |
Fri, 02 Jun, 06:41 |
|
kafka git commit: KAFKA-5364; Don't fail producer if drained partition is not yet in transaction |
|
| j...@apache.org |
kafka git commit: KAFKA-5364; Don't fail producer if drained partition is not yet in transaction |
Fri, 02 Jun, 07:53 |
| j...@apache.org |
kafka git commit: KAFKA-5364; Don't fail producer if drained partition is not yet in transaction |
Fri, 02 Jun, 07:53 |
|
kafka git commit: KAFKA-5311: Support ExtendedDeserializer in Kafka Streams |
|
| ij...@apache.org |
kafka git commit: KAFKA-5311: Support ExtendedDeserializer in Kafka Streams |
Fri, 02 Jun, 08:26 |
| ij...@apache.org |
kafka git commit: KAFKA-5311: Support ExtendedDeserializer in Kafka Streams |
Fri, 02 Jun, 08:26 |
|
kafka git commit: KAFKA-5365; Fix regression in compressed message iteration affecting magic v0 and v1 |
|
| ij...@apache.org |
kafka git commit: KAFKA-5365; Fix regression in compressed message iteration affecting magic v0 and v1 |
Fri, 02 Jun, 08:44 |
| ij...@apache.org |
kafka git commit: KAFKA-5365; Fix regression in compressed message iteration affecting magic v0 and v1 |
Fri, 02 Jun, 08:46 |
| ij...@apache.org |
kafka git commit: KAFKA-5365; Fix regression in compressed message iteration affecting magic v0 and v1 [Forced Update!] |
Fri, 02 Jun, 08:45 |
|
kafka git commit: KAFKA-5282; Use a factory method to create producers/consumers and close them in tearDown |
|
| ij...@apache.org |
kafka git commit: KAFKA-5282; Use a factory method to create producers/consumers and close them in tearDown |
Fri, 02 Jun, 09:26 |
| ij...@apache.org |
kafka git commit: KAFKA-5282; Use a factory method to create producers/consumers and close them in tearDown |
Fri, 02 Jun, 09:27 |
|
kafka git commit: KAFKA-3264; Deprecate the old Scala consumer (KIP-109) |
|
| ij...@apache.org |
kafka git commit: KAFKA-3264; Deprecate the old Scala consumer (KIP-109) |
Fri, 02 Jun, 11:30 |
| ij...@apache.org |
kafka git commit: KAFKA-3264; Deprecate the old Scala consumer (KIP-109) |
Fri, 02 Jun, 11:30 |
|
kafka git commit: KAFKA-5164: Ensure SetSchemaMetadata updates key or value when Schema changes |
|
| ewe...@apache.org |
kafka git commit: KAFKA-5164: Ensure SetSchemaMetadata updates key or value when Schema changes |
Fri, 02 Jun, 17:02 |
| ewe...@apache.org |
kafka git commit: KAFKA-5164: Ensure SetSchemaMetadata updates key or value when Schema changes |
Fri, 02 Jun, 17:02 |
|
kafka git commit: KAFKA-5327: ConsoleConsumer should manually commit offsets for records that are returned in receive() |
|
| guozh...@apache.org |
kafka git commit: KAFKA-5327: ConsoleConsumer should manually commit offsets for records that are returned in receive() |
Fri, 02 Jun, 19:08 |
| guozh...@apache.org |
kafka git commit: KAFKA-5327: ConsoleConsumer should manually commit offsets for records that are returned in receive() |
Fri, 02 Jun, 19:08 |
|
kafka git commit: KAFKA-5368: Fix skipped record metrics to use rate of sum instead of rate of count |
|
| guozh...@apache.org |
kafka git commit: KAFKA-5368: Fix skipped record metrics to use rate of sum instead of rate of count |
Fri, 02 Jun, 19:21 |
| guozh...@apache.org |
kafka git commit: KAFKA-5368: Fix skipped record metrics to use rate of sum instead of rate of count |
Fri, 02 Jun, 19:21 |
|
kafka git commit: KAFKA-3982: Fix processing order of some of the consumer properties |
|
| guozh...@apache.org |
kafka git commit: KAFKA-3982: Fix processing order of some of the consumer properties |
Fri, 02 Jun, 19:38 |
| guozh...@apache.org |
kafka git commit: KAFKA-3982: Fix processing order of some of the consumer properties |
Fri, 02 Jun, 19:38 |
|
kafka git commit: KAFKA-5236; Increase the block/buffer size when compressing with Snappy or Gzip |
|
| ij...@apache.org |
kafka git commit: KAFKA-5236; Increase the block/buffer size when compressing with Snappy or Gzip |
Fri, 02 Jun, 20:20 |
| ij...@apache.org |
kafka git commit: KAFKA-5236; Increase the block/buffer size when compressing with Snappy or Gzip |
Fri, 02 Jun, 20:20 |
|
kafka git commit: KAFKA-5322; Add `OPERATION_NOT_ATTEMPTED` error code to resolve AddPartitionsToTxn inconsistency |
|
| j...@apache.org |
kafka git commit: KAFKA-5322; Add `OPERATION_NOT_ATTEMPTED` error code to resolve AddPartitionsToTxn inconsistency |
Fri, 02 Jun, 21:23 |
| j...@apache.org |
kafka git commit: KAFKA-5322; Add `OPERATION_NOT_ATTEMPTED` error code to resolve AddPartitionsToTxn inconsistency |
Fri, 02 Jun, 21:23 |
|
kafka git commit: HOTFIX: Reinstate the placeholder for logPrefix in TransactionManager |
|
| j...@apache.org |
kafka git commit: HOTFIX: Reinstate the placeholder for logPrefix in TransactionManager |
Fri, 02 Jun, 22:29 |
| j...@apache.org |
kafka git commit: HOTFIX: Reinstate the placeholder for logPrefix in TransactionManager |
Fri, 02 Jun, 22:29 |
|
kafka git commit: KAFKA-5373; Revert breaking change to console consumer |
|
| ij...@apache.org |
kafka git commit: KAFKA-5373; Revert breaking change to console consumer |
Sat, 03 Jun, 00:53 |
| ij...@apache.org |
kafka git commit: KAFKA-5373; Revert breaking change to console consumer |
Sat, 03 Jun, 00:53 |
|
kafka git commit: MINOR: Reuse decompression buffers in log cleaner |
|
| ij...@apache.org |
kafka git commit: MINOR: Reuse decompression buffers in log cleaner |
Sat, 03 Jun, 01:07 |
| ij...@apache.org |
kafka git commit: MINOR: Reuse decompression buffers in log cleaner |
Sat, 03 Jun, 01:08 |
|
kafka git commit: KAFKA-5272; Policy for Alter Configs (KIP-133) |
|
| ij...@apache.org |
kafka git commit: KAFKA-5272; Policy for Alter Configs (KIP-133) |
Sat, 03 Jun, 02:14 |
| ij...@apache.org |
kafka git commit: KAFKA-5272; Policy for Alter Configs (KIP-133) |
Sat, 03 Jun, 02:15 |
|
kafka git commit: KAFKA-5355; DelayedFetch should propagate isolation level to log read |
|
| ij...@apache.org |
kafka git commit: KAFKA-5355; DelayedFetch should propagate isolation level to log read |
Sat, 03 Jun, 05:24 |
| ij...@apache.org |
kafka git commit: KAFKA-5355; DelayedFetch should propagate isolation level to log read |
Sat, 03 Jun, 05:24 |