| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-7228: Set errorHandlingMetrics for dead letter queue |
Thu, 02 Aug, 21:36 |
| ewe...@apache.org |
[kafka] branch 2.0 updated: KAFKA-7228: Set errorHandlingMetrics for dead letter queue |
Thu, 02 Aug, 21:37 |
| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-7225: Pretransform validated props |
Tue, 07 Aug, 20:18 |
| ewe...@apache.org |
[kafka] branch 2.0 updated: KAFKA-7225: Pretransform validated props |
Tue, 07 Aug, 20:18 |
| ewe...@apache.org |
[kafka] branch trunk updated: MINOR: Add connector configs to site-docs |
Tue, 07 Aug, 21:34 |
| ewe...@apache.org |
[kafka] branch trunk updated: MINOR: System test for error handling and writes to DeadLetterQueue |
Tue, 07 Aug, 21:44 |
| ewe...@apache.org |
[kafka] branch 2.0 updated: MINOR: System test for error handling and writes to DeadLetterQueue |
Tue, 07 Aug, 21:44 |
| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-7242: Reverse xform configs before saving (KIP-297) |
Tue, 28 Aug, 19:59 |
| ewe...@apache.org |
[kafka] branch 2.0 updated: KAFKA-7242: Reverse xform configs before saving (KIP-297) |
Tue, 28 Aug, 19:59 |
| guozh...@apache.org |
[kafka] branch 2.0 updated (084f4d2 -> b367360) |
Wed, 01 Aug, 01:13 |
| guozh...@apache.org |
[kafka] 01/02: KAFKA-7192: Wipe out if EOS is turned on and checkpoint file does not exist (#5421) |
Wed, 01 Aug, 01:13 |
| guozh...@apache.org |
[kafka] 02/02: KAFKA-7192 Follow-up: update checkpoint to the reset beginning offset (#5430) |
Wed, 01 Aug, 01:13 |
| guozh...@apache.org |
[kafka] branch 2.0 updated: KAFKA-7144: Fix task assignment to be even (#5390) |
Wed, 01 Aug, 16:48 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Remove 1 minute minimum segment interval (#5323) |
Wed, 01 Aug, 18:01 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-7161: check invariant: oldValue is in the state (#5366) |
Wed, 01 Aug, 18:02 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6761: Construct Physical Plan using Graph, Reduce streams footprint part III (#5201) |
Wed, 01 Aug, 22:01 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-3514: Part II, Choose tasks with data on all partitions to process (#5398) |
Fri, 03 Aug, 01:35 |
| guozh...@apache.org |
[kafka] branch 2.0 updated: MINOR: fix metric sensor names in Streams (#5455) |
Fri, 03 Aug, 18:22 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: clean up node and store sensors (#5450) |
Sat, 04 Aug, 05:43 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: close producer instance in AbstractJoinIntegrationTest (#5459) |
Sat, 04 Aug, 16:41 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: increase timeout values in streams tests (#5461) |
Mon, 06 Aug, 16:13 |
| guozh...@apache.org |
[kafka-site] branch asf-site updated: MINOR: fix Streams state.dir config (#159) |
Mon, 06 Aug, 20:39 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: fix Streams docs state.dir (#5465) |
Mon, 06 Aug, 20:39 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-7250: fix transform function in scala DSL to accept TranformerSupplier (#5468) |
Tue, 07 Aug, 15:00 |
| guozh...@apache.org |
[kafka] branch 2.0 updated: KAFKA-7250: fix transform function in scala DSL to accept TranformerSupplier (#5468) |
Tue, 07 Aug, 15:02 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Fix Streams scala format violations (#5472) |
Tue, 07 Aug, 19:50 |
| guozh...@apache.org |
[kafka] branch 2.0 updated: MINOR: Fix Streams scala format violations (#5472) |
Tue, 07 Aug, 19:51 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: add spotlessScalaCheck to jenkins job (#5473) |
Tue, 07 Aug, 22:48 |
| guozh...@apache.org |
[kafka] branch 2.0 updated: MINOR: Add Scalafmt to Streams Scala API (#4965) |
Tue, 07 Aug, 23:12 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-7158: Add unit test for window store range queries (#5466) |
Wed, 08 Aug, 20:53 |
| guozh...@apache.org |
[kafka] branch 2.0 updated: KAFKA-7080: pass segmentInterval to CachingWindowStore (#5474) |
Wed, 08 Aug, 21:00 |
| guozh...@apache.org |
[kafka] branch 2.0 updated: KAFKA-7158: Add unit test for window store range queries (#5466) |
Wed, 08 Aug, 21:02 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Follow up for KAFKA-6761 graph should add stores for consistency (#5453) |
Wed, 08 Aug, 22:41 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-7250: switch scala transform to TransformSupplier (#5481) |
Thu, 09 Aug, 17:12 |
| guozh...@apache.org |
[kafka] branch 2.0 updated: KAFKA-7250: switch scala transform to TransformSupplier (#5481) |
Thu, 09 Aug, 17:12 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Add spotlessScalaCheck dependency to streams-scala test task (#5479) |
Mon, 13 Aug, 16:25 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-7222: Add Windows grace period (#5369) |
Tue, 14 Aug, 16:53 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6761: Reduce streams footprint part IV add optimization (#5451) |
Wed, 15 Aug, 00:46 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: (re)add equals/hashCode to *Windows (#5510) |
Wed, 15 Aug, 21:30 |
| guozh...@apache.org |
[kafka] branch 1.1 updated: KAFKA-7284: streams should unwrap fenced exception (#5513) |
Wed, 15 Aug, 22:49 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6998: Disable Caching when max.cache.bytes are zero. (#5488) |
Fri, 17 Aug, 16:35 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Update test to wait for final value to reduce flakiness updated test method for multiple keys (#5517) |
Fri, 17 Aug, 19:14 |
| guozh...@apache.org |
[kafka] branch trunk updated: Minor: add valueChangingOperation and mergeNode to StreamsGraphNode#toString (#5522) |
Fri, 17 Aug, 23:14 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-7311: Reset next batch expiry time on each poll loop |
Mon, 20 Aug, 19:41 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Small refactorings on KTable joins (#5540) |
Tue, 21 Aug, 21:42 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-7301: Fix streams Scala join ambiguous overload (#5502) |
Tue, 21 Aug, 22:41 |
| guozh...@apache.org |
[kafka] branch 2.0 updated: KAFKA-7301: Fix streams Scala join ambiguous overload (#5502) |
Tue, 21 Aug, 23:38 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-7316: Fix Streams Scala filter recursive call #5538 |
Thu, 23 Aug, 16:15 |
| guozh...@apache.org |
[kafka] branch 2.0 updated: KAFKA-7316: Fix Streams Scala filter recursive call #5538 |
Thu, 23 Aug, 16:16 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Return correct instance of SessionWindowSerde (#5546) |
Thu, 23 Aug, 20:39 |
| guozh...@apache.org |
[kafka] branch 2.0 updated: MINOR: Return correct instance of SessionWindowSerde (#5546) |
Thu, 23 Aug, 20:42 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Fix streams Scala foreach recursive call (#5539) |
Fri, 24 Aug, 00:07 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: replace deprecated remove with delete (#5565) |
Fri, 24 Aug, 15:54 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-7240: -total metrics in Streams are incorrect (#5467) |
Fri, 24 Aug, 18:21 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Correct folder for package object scala (#5573) |
Tue, 28 Aug, 01:44 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Fix streams Scala peek recursive call (#5566) |
Wed, 29 Aug, 16:34 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-7269: Add docs for KStream.merge (#5512) |
Wed, 29 Aug, 16:34 |
| guozh...@apache.org |
[kafka] branch 2.0 updated: MINOR: Fix streams Scala foreach recursive call (#5539) |
Wed, 29 Aug, 17:22 |
| guozh...@apache.org |
[kafka] branch 2.0 updated: MINOR: Fix streams Scala peek recursive call (#5566) |
Wed, 29 Aug, 17:23 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR:Use StoreBuilder.name() for node name (#5588) |
Thu, 30 Aug, 00:42 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: single Jackson serde for PageViewTypedDemo (#5590) |
Fri, 31 Aug, 20:13 |
| ij...@apache.org |
[kafka] branch trunk updated: KAFKA-7308: Fix rat and checkstyle config for Java 11 support (#5529) |
Sat, 18 Aug, 15:18 |
| ij...@apache.org |
[kafka] branch trunk updated: KAFKA-7210: Add system test to verify log compaction (#5226) |
Mon, 20 Aug, 10:47 |
| ij...@apache.org |
[kafka] branch trunk updated: MINOR: Split at first occurrence of '=' in kafka.py props parsing (#5549) |
Wed, 22 Aug, 06:43 |
| ij...@apache.org |
[kafka] branch trunk updated: MINOR: Fix side-effecting nullary methods warning in JsonValueTest (#5493) |
Thu, 23 Aug, 08:36 |
| ij...@apache.org |
[kafka] branch trunk updated: MINOR: Use method references instead of anonymus classes in Errors (#5525) |
Thu, 23 Aug, 08:44 |
| ij...@apache.org |
[kafka] branch trunk updated: MINOR: Eliminate warnings from KafkaProducerTest (#5548) |
Thu, 23 Aug, 13:40 |
| ij...@apache.org |
[kafka] branch trunk updated: MINOR: Remove unused compressionType parameter from TestUtils.produceMessages (#5569) |
Sat, 25 Aug, 15:49 |
| ij...@apache.org |
[kafka] branch trunk updated: MINOR: Fix swallowed NPE in KafkaServer.close() (#5339) |
Wed, 29 Aug, 23:01 |
| ij...@apache.org |
[kafka] branch trunk updated: KAFKA-7338: Specify AES128 default encryption type for Kerberos tests (#5586) |
Thu, 30 Aug, 15:19 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: Producers should set delivery timeout instead of retries (#5425) |
Wed, 01 Aug, 18:04 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-7231; Ensure NetworkClient uses overridden request timeout (#5444) |
Thu, 02 Aug, 18:02 |
| j...@apache.org |
[kafka] branch 2.0 updated: KAFKA-7231; Ensure NetworkClient uses overridden request timeout (#5444) |
Thu, 02 Aug, 18:05 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: Add Timer to simplify timeout bookkeeping and use it in the consumer (#5087) |
Sat, 04 Aug, 00:25 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: Log AdminClient configs (#5457) |
Tue, 07 Aug, 00:56 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: Fix minikdc cleanup in system tests (#5471) |
Tue, 07 Aug, 18:08 |
| j...@apache.org |
[kafka] branch 2.0 updated: MINOR: Fix minikdc cleanup in system tests (#5471) |
Tue, 07 Aug, 20:25 |
| j...@apache.org |
[kafka] branch 1.1 updated: MINOR: Fix minikdc cleanup in system tests (#5471) |
Tue, 07 Aug, 20:25 |
| j...@apache.org |
[kafka] branch 1.0 updated: MINOR: Fix minikdc cleanup in system tests (#5471) |
Tue, 07 Aug, 20:26 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-4950; Fix ConcurrentModificationException on assigned-partitions metric update (#3907) |
Wed, 08 Aug, 22:43 |
| j...@apache.org |
[kafka] branch 2.0 updated: KAFKA-4950; Fix ConcurrentModificationException on assigned-partitions metric update (#3907) |
Wed, 08 Aug, 22:51 |
| j...@apache.org |
[kafka] branch 2.0 updated: HOTFIX: Fix compilation error in ConsumerCoordinatorTest |
Wed, 08 Aug, 22:52 |
| j...@apache.org |
[kafka] branch 1.1 updated: KAFKA-4950; Fix ConcurrentModificationException on assigned-partitions metric update (#3907) |
Wed, 08 Aug, 22:59 |
| j...@apache.org |
[kafka] branch 1.0 updated: KAFKA-4950; Fix ConcurrentModificationException on assigned-partitions metric update (#3907) |
Wed, 08 Aug, 23:01 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6751; Support dynamic configuration of max.connections.per.ip/max.connections.per.ip.overrides configs (KIP-308) (#5334) |
Thu, 09 Aug, 21:40 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-7140; Remove deprecated poll usages (#5319) |
Sat, 11 Aug, 05:51 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-7164; Follower should truncate after every missed leader epoch change (#5436) |
Mon, 13 Aug, 06:30 |
| j...@apache.org |
[kafka] branch 2.0 updated: KAFKA-7164; Follower should truncate after every missed leader epoch change (#5436) |
Mon, 13 Aug, 06:42 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-5638; Improve the Required ACL of ListGroups API (KIP-231) (#5352) |
Mon, 13 Aug, 06:59 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: Remove AbstractFetcherThread.PartitionData (#5233) |
Mon, 13 Aug, 17:41 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: Use statically compiled regular expressions for efficiency (#5168) |
Tue, 14 Aug, 00:31 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: Clean up to avoid errors in dynamic broker config tests (#5486) |
Tue, 14 Aug, 16:14 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: Use explicit construction of clients in IntegrationTestHarness (#5443) |
Tue, 14 Aug, 21:34 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-7296; Handle coordinator loading error in TxnOffsetCommit (#5514) |
Thu, 16 Aug, 16:37 |
| j...@apache.org |
[kafka] branch 2.0 updated: KAFKA-7296; Handle coordinator loading error in TxnOffsetCommit (#5514) |
Thu, 16 Aug, 17:06 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-7298; Raise UnknownProducerIdException if next sequence number is unknown (#5518) |
Mon, 20 Aug, 16:00 |
| j...@apache.org |
[kafka] branch 2.0 updated: KAFKA-7298; Raise UnknownProducerIdException if next sequence number is unknown (#5518) |
Mon, 20 Aug, 16:06 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-7278; replaceSegments() should not call asyncDeleteSegment() for segments which have been removed from segments list (#5491) |
Mon, 20 Aug, 18:01 |
| j...@apache.org |
[kafka] branch 2.0 updated: KAFKA-7278; replaceSegments() should not call asyncDeleteSegment() for segments which have been removed from segments list (#5491) |
Mon, 20 Aug, 18:03 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6312; Document --reset-offsets option for consumer group tool (#4527) |
Mon, 20 Aug, 20:27 |