| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-6566: Improve Connect Resource Cleanup |
Fri, 18 May, 17:40 |
| ewe...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6566: Improve Connect Resource Cleanup |
Fri, 18 May, 17:40 |
| ewe...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6566: Improve Connect Resource Cleanup |
Fri, 18 May, 17:40 |
| ewe...@apache.org |
[kafka] branch 0.11.0 updated: KAFKA-6566: Improve Connect Resource Cleanup |
Fri, 18 May, 17:41 |
| ewe...@apache.org |
[kafka] branch 0.10.2 updated: KAFKA-6566: Improve Connect Resource Cleanup |
Fri, 18 May, 17:45 |
| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-6685: Added Exception to distinguish message Key from Value during deserializing. |
Tue, 22 May, 04:10 |
| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-5807 - Check Connector.config() and Transformation.config() returns a valid ConfigDef |
Tue, 22 May, 20:56 |
| ewe...@apache.org |
[kafka] branch trunk updated (3a8d3a7 -> a64ab91) |
Tue, 29 May, 23:24 |
| ewe...@apache.org |
[kafka] branch trunk updated (4943c3f -> fffb9c5) |
Tue, 29 May, 23:37 |
| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-6776: ConnectRestExtension Interfaces & Rest integration (KIP-285) |
Wed, 30 May, 04:36 |
| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-6738: Implement error handling for source and sink tasks (KIP-298) |
Wed, 30 May, 18:39 |
| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-6886: Externalize secrets from Connect configs (KIP-297) |
Wed, 30 May, 21:43 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6825: Make StreamsConfig#DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG public (#4929) |
Wed, 02 May, 18:58 |
| guozh...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6825: Make StreamsConfig#DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG public (#4929) |
Wed, 02 May, 18:59 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6657: Add StreamsConfig prefix for different consumers (#4805) |
Wed, 02 May, 20:24 |
| guozh...@apache.org |
[kafka] branch trunk updated: HOTFIX: Simplify ConsoleConsumer stripWithPrefix function |
Wed, 02 May, 20:32 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6829: retry commits on unknown topic or partition (#4948) |
Thu, 03 May, 00:01 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6761: Part 1 of 3; Graph nodes (#4923) |
Fri, 04 May, 15:40 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Removed deprecated schedule function (#4908) |
Fri, 04 May, 15:42 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-5697: issue Consumer#wakeup during Streams shutdown |
Fri, 04 May, 16:06 |
| guozh...@apache.org |
[kafka-site] branch asf-site updated: [KAFKA-6861] Missing ')' in Kafka Streams documentation (#139) |
Fri, 04 May, 16:54 |
| guozh...@apache.org |
[kafka-site] branch asf-site updated: MINOR: fix tutorial example code snippet |
Fri, 04 May, 16:58 |
| guozh...@apache.org |
[kafka] branch trunk updated: HOTFIX: fix streams tutorial code example |
Fri, 04 May, 16:59 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6844: Call shutdown on GlobalStreamThread after all StreamThreads have stopped (#4950) |
Fri, 04 May, 22:18 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Remove KafkaStreams#toString (#4909) |
Fri, 04 May, 23:35 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Build and code sample updates for Kafka Streams DSL for Scala (#4949) |
Mon, 07 May, 03:55 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6474: Rewrite tests to use new public TopologyTestDriver [cleanup] (#4939) |
Mon, 07 May, 16:21 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Remove deprecated parameter in ProcessorContext#register (#4911) |
Mon, 07 May, 16:22 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Remove deprecated KTable#writeAs, print, foreach, to, through (#4910) |
Mon, 07 May, 16:44 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6628: RocksDBSegmentedBytesStoreTest does not cover time window serdes (#4836) |
Mon, 07 May, 17:57 |
| guozh...@apache.org |
[kafka-site] branch asf-site updated: MINOR: Fix typo in table (#140) |
Mon, 07 May, 19:48 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6813: Remove deprecated APIs in KIP-182, Part I (#4919) |
Tue, 08 May, 00:34 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Make Serdes less confusing in Scala (#4963) |
Tue, 08 May, 16:15 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA 6673: Implemented missing override equals method (#4745) |
Wed, 09 May, 17:34 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6878: NPE when querying global state store not in READY state (#4978) |
Wed, 09 May, 17:42 |
| guozh...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6878: NPE when querying global state store not in READY state (#4978) |
Wed, 09 May, 17:48 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6878 Switch the order of underlying.init and initInternal (#4988) |
Thu, 10 May, 00:06 |
| guozh...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6878 Switch the order of underlying.init and initInternal (#4988) |
Thu, 10 May, 00:07 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6813: Remove deprecated APIs in KIP-182, Part II (#4976) |
Thu, 10 May, 00:13 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Remove deprecated valueTransformer.punctuate (#4993) |
Thu, 10 May, 16:51 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6894: Improve err msg when connecting processor with global store (#5000) |
Thu, 10 May, 22:49 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-5965: Remove Deprecated AdminClient from Streams Resetter Tool (#4968) |
Fri, 11 May, 15:44 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Count fix and Type alias refactor in Streams Scala API (#4966) |
Fri, 11 May, 17:15 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6813: Remove deprecated APIs in KIP-182, Part III (#4991) |
Fri, 11 May, 18:38 |
| guozh...@apache.org |
[kafka] branch trunk updated: HOTFIX: RegexSourceIntegrationTest needs to cleanup shared output topic (#5008) |
Fri, 11 May, 20:53 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6896: Add producer metrics exporting in KafkaStreams (#4998) |
Tue, 15 May, 21:29 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: doc change for deprecate removal (#5006) |
Wed, 16 May, 03:26 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6905: Document that Processors may be re-used by Streams (#5022) |
Wed, 16 May, 20:10 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: fix broken links in streams doc (#5025) |
Wed, 16 May, 20:23 |
| guozh...@apache.org |
[kafka] branch 1.1 updated: MINOR: fix broken links in streams doc (#5025) |
Wed, 16 May, 20:24 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Use Set instead of List for multiple topics (#5024) |
Thu, 17 May, 15:45 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6729: Reuse source topics for source KTable's materialized store's changelog (#5017) |
Thu, 17 May, 18:28 |
| guozh...@apache.org |
[kafka] branch trunk updated: HOTFIX: move Conusmed to o.a.k.streams.kstream (#5033) |
Thu, 17 May, 18:56 |
| guozh...@apache.org |
[kafka] branch trunk updated: HOTFIX: use ConsumedInternal in StreamsBuilder |
Fri, 18 May, 00:20 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-5697: revert wakeup-based impl (#5035) |
Fri, 18 May, 15:05 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Remove unused class (#5037) |
Fri, 18 May, 17:58 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6849: add transformValues methods to KTable. (#4959) |
Fri, 18 May, 23:06 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6905: Document that Transformers may be re-used by Streams (#5026) |
Sun, 20 May, 01:44 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6729: Follow up; disable logging for source KTable. (#5038) |
Sun, 20 May, 17:24 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Fix type inference on joins and aggregates (#5019) |
Sun, 20 May, 23:25 |
| guozh...@apache.org |
[kafka] branch 1.1 updated: MINOR: Do not start processor for bounce-at-start (#4639) |
Mon, 21 May, 01:25 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Reduce required occurrance from 100 to 10 (#5048) |
Mon, 21 May, 18:50 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Ignore test_broker_type_bounce_at_start system test (#5055) |
Tue, 22 May, 00:28 |
| guozh...@apache.org |
[kafka-site] branch asf-site updated: MINOR: Fix link in num.standby.replicas section (#142) |
Tue, 22 May, 00:34 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6474: Rewrite tests to use new public TopologyTestDriver [part 3] (#5052) |
Tue, 22 May, 15:49 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: reduce commit time on test (#5095) |
Tue, 29 May, 23:33 |
| guozh...@apache.org |
[kafka] branch trunk updated: Update doc of curried joins and aggregates (#5053) |
Wed, 30 May, 18:04 |
| guozh...@apache.org |
[kafka] branch trunk updated: Remove duplicate code which is invoked twice (#5039) |
Wed, 30 May, 18:09 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6957 make InternalTopologyBuilder accessible from AbstractStream subclasses (#5085) |
Wed, 30 May, 18:13 |
| ij...@apache.org |
[kafka] branch trunk updated: MINOR: Removed unused imports in a few tests (#4938) |
Tue, 01 May, 22:27 |
| ij...@apache.org |
[kafka] branch trunk updated: Upgrade ZooKeeper to 3.4.12 and Scala to 2.12.6 (#4940) |
Thu, 03 May, 16:25 |
| ij...@apache.org |
[kafka] branch trunk updated: KAFKA-6853: ZooKeeperRequestLatencyMs is incorrect (#4961) |
Thu, 03 May, 16:46 |
| ij...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6853: ZooKeeperRequestLatencyMs is incorrect (#4961) |
Thu, 03 May, 16:48 |
| ij...@apache.org |
[kafka] branch trunk updated: KAFKA-6879; Invoke session init callbacks outside lock to avoid Controller deadlock (#4977) |
Tue, 08 May, 22:52 |
| ij...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6879; Invoke session init callbacks outside lock to avoid Controller deadlock (#4977) |
Tue, 08 May, 22:59 |
| ij...@apache.org |
[kafka] branch trunk updated: MINOR: Fix trace logging in ReplicaManager (#4916) |
Wed, 09 May, 06:02 |
| ij...@apache.org |
[kafka] branch trunk updated: MINOR: Rename RecordFormat to RecordVersion (#4809) |
Fri, 11 May, 05:06 |
| ij...@apache.org |
[kafka] branch 0.11.0 updated: KAFKA-6307: Fix KafkaMbean leak in JmxReporter (#4307) |
Mon, 14 May, 21:12 |
| ij...@apache.org |
[kafka] branch 0.11.0 updated: KAFKA-6857; Leader should reply with undefined offset if undefined leader epoch requested (#4967) |
Mon, 14 May, 21:25 |
| ij...@apache.org |
[kafka] branch trunk updated: KAFKA-4423: Drop support for Java 7 (KIP-118) and update deps (#5046) |
Tue, 22 May, 06:17 |
| ij...@apache.org |
[kafka] branch trunk updated: MINOR: Remove unnecessary conditional in KafkaAdminClient to fix checkstyle (#5058) |
Tue, 22 May, 07:15 |
| ij...@apache.org |
[kafka] branch trunk updated: MINOR: Use reflection for signal handler and do not enable it for IBM JDK (#5047) |
Fri, 25 May, 14:01 |
| ij...@apache.org |
[kafka] branch 1.1 updated: MINOR: Use reflection for signal handler and do not enable it for IBM JDK (#5047) |
Fri, 25 May, 14:02 |
| ij...@apache.org |
[kafka] branch trunk updated: KAFKA-6930: Convert byte array to string in KafkaZkClient debug log (#5061) |
Fri, 25 May, 23:26 |
| ij...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6930: Convert byte array to string in KafkaZkClient debug log (#5061) |
Fri, 25 May, 23:28 |
| ij...@apache.org |
[kafka] branch trunk updated: MINOR: Replace unused variables by underscore (#5003) |
Sat, 26 May, 07:54 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6854; Handle batches deleted during log cleaning of logs with txns (#4962) |
Thu, 03 May, 20:05 |
| j...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6854; Handle batches deleted during log cleaning of logs with txns (#4962) |
Thu, 03 May, 20:09 |
| j...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6854; Handle batches deleted during log cleaning of logs with txns (#4962) |
Thu, 03 May, 20:12 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6857; Leader should reply with undefined offset if undefined leader epoch requested (#4967) |
Fri, 04 May, 06:06 |
| j...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6857; Leader should reply with undefined offset if undefined leader epoch requested (#4967) |
Fri, 04 May, 07:48 |
| j...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6857; Leader should reply with undefined offset if undefined leader epoch requested (#4967) |
Fri, 04 May, 15:30 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6867; Corrected the typos in upgrade.html (#4970) |
Fri, 04 May, 22:42 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6292; Improve FileLogInputStream batch position checks to avoid type overflow (#4928) |
Wed, 09 May, 00:07 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6299; Fix AdminClient error handling when metadata changes (#4295) |
Wed, 09 May, 21:27 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: Update dynamic broker configuration doc for truststore update (#4954) |
Thu, 10 May, 15:55 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: Fix typo in ConsumerRebalanceListener JavaDoc (#4996) |
Thu, 10 May, 16:53 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6893; Create processors before starting acceptor in SocketServer (#4999) |
Thu, 10 May, 21:18 |
| j...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6893; Create processors before starting acceptor in SocketServer (#4999) |
Thu, 10 May, 21:22 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: A few small cleanups in AdminClient from KAFKA-6299 (#4989) |
Fri, 11 May, 00:31 |