| j...@apache.org |
kafka git commit: MINOR: Fix issue in `AsyncProducerTest` where it expects the `port` config to be set |
Tue, 01 Nov, 15:42 |
| guozh...@apache.org |
kafka git commit: KAFKA-4361: Streams does not respect user configs for "default" params |
Tue, 01 Nov, 17:08 |
| guozh...@apache.org |
kafka git commit: KAFKA-4302: Simplify KTableSource |
Tue, 01 Nov, 17:20 |
| guozh...@apache.org |
kafka git commit: HOTFIX: improve error message on invalid input record timestamp |
Tue, 01 Nov, 17:22 |
| guozh...@apache.org |
kafka git commit: KAFKA-4352: instable ResetTool integration test |
Tue, 01 Nov, 17:30 |
| guozh...@apache.org |
kafka git commit: KAFKA-4352: instable ResetTool integration test |
Tue, 01 Nov, 17:31 |
| j...@apache.org |
kafka git commit: KAFKA-4357; Fix consumer group describe output when there is no active member (old consumer) |
Tue, 01 Nov, 19:31 |
| gwens...@apache.org |
kafka git commit: MINOR: Fix documentation of compaction |
Wed, 02 Nov, 01:17 |
| j...@apache.org |
kafka git commit: MINOR: Replaced unnecessary isDefined and get on option values with fold |
Wed, 02 Nov, 05:38 |
| gwens...@apache.org |
kafka git commit: MINOR: Fix NPE when Connect offset contains non-primitive type |
Wed, 02 Nov, 17:27 |
| j...@apache.org |
kafka-site git commit: Add Becket to the committers page |
Wed, 02 Nov, 20:44 |
| ij...@apache.org |
kafka git commit: MINOR: Remove stray `%s` in `TopicMetadata.toString` |
Thu, 03 Nov, 11:01 |
| j...@apache.org |
kafka git commit: KAFKA-4024; Override client metadata backoff on topic changes and avoid unnecessary connections |
Fri, 04 Nov, 06:19 |
| j...@apache.org |
kafka git commit: MINOR: Add description of how consumer wakeup acts if no threads are awakened |
Fri, 04 Nov, 07:38 |
| ewe...@apache.org |
kafka git commit: KAFKA-4372: Kafka Connect REST API does not handle DELETE of connector with slashes in their names |
Fri, 04 Nov, 17:44 |
| ewe...@apache.org |
kafka git commit: MINOR: missing fullstop in doc for `max.partition.fetch.bytes` |
Fri, 04 Nov, 20:29 |
| ewe...@apache.org |
kafka git commit: MINOR: Fix re-raise of python error in system tests |
Fri, 04 Nov, 22:57 |
| j...@apache.org |
kafka git commit: MINOR: Fix regex on connector path param in ConnectorsResource |
Mon, 07 Nov, 16:48 |
| ewe...@apache.org |
kafka git commit: KAFKA-4284: Make Partitioner a Closeable and close it when closing the producer |
Tue, 08 Nov, 17:53 |
| guozh...@apache.org |
kafka git commit: KAFKA-4269: Follow up for 0.10.1 branch -update topic subscriptions for regex |
Tue, 08 Nov, 20:03 |
| guozh...@apache.org |
kafka git commit: MINOR: remove commented out code and System.out.println |
Tue, 08 Nov, 20:10 |
| ewe...@apache.org |
kafka git commit: MINOR: some trace logging for streams debugging |
Tue, 08 Nov, 22:49 |
| guozh...@apache.org |
kafka git commit: KAFKA-4360：Controller may deadLock when autoLeaderRebalance encounter zk expired |
Wed, 09 Nov, 18:38 |
| guozh...@apache.org |
kafka git commit: MINOR: fix typos and incorrect docs |
Wed, 09 Nov, 18:41 |
| guozh...@apache.org |
kafka git commit: KAFKA-4311: Multi layer cache eviction causes forwarding to incorrect ProcessorNode |
Wed, 09 Nov, 18:43 |
| j...@apache.org |
kafka-site git commit: Update the website repo link in code.html to point to github. |
Wed, 09 Nov, 18:52 |
| guozh...@apache.org |
kafka git commit: MINOR: remove unused fields from KTableImpl |
Wed, 09 Nov, 19:17 |
| guozh...@apache.org |
kafka git commit: MINOR: fix incorrect logging in StreamThread |
Wed, 09 Nov, 19:22 |
| ewe...@apache.org |
kafka git commit: KAFKA-4364: Remove secrets from DEBUG logging |
Wed, 09 Nov, 22:58 |
| guozh...@apache.org |
kafka git commit: MINOR: add upgrade guide for Kafka Streams API |
Wed, 09 Nov, 23:31 |
| guozh...@apache.org |
kafka git commit: MINOR: add upgrade guide for Kafka Streams API |
Wed, 09 Nov, 23:31 |
| guozh...@apache.org |
kafka git commit: revert streams/src/main/java/org/apache/kafka/streams/processor/ConsumerRecordTimestampExtractor.java |
Thu, 10 Nov, 15:17 |
| guozh...@apache.org |
kafka git commit: MINOR: improve exception message for incompatible Serdes to actual key/value data types |
Fri, 11 Nov, 01:06 |
| guozh...@apache.org |
kafka git commit: HOTFIX: failing to close this iterator causes leaks in rocksdb |
Fri, 11 Nov, 14:36 |
| guozh...@apache.org |
kafka git commit: HOTFIX: failing to close this iterator causes leaks in rocksdb |
Fri, 11 Nov, 14:36 |
| ewe...@apache.org |
kafka git commit: MINOR: Extend mirror maker test to include interceptors |
Fri, 11 Nov, 17:10 |
| guozh...@apache.org |
kafka git commit: KAFKA-4379: Remove caching of dirty and removed keys from StoreChangeLogger |
Fri, 11 Nov, 18:21 |
| j...@apache.org |
kafka git commit: KAFKA-4081; KafkaConsumer should not allow negative offsets to be committed |
Fri, 11 Nov, 18:37 |
| ewe...@apache.org |
kafka git commit: MINOR: Fix export command for additional env vars in connect system tests |
Fri, 11 Nov, 23:00 |
| ewe...@apache.org |
kafka git commit: KAFKA-3829: Ensure valid configuration prior to creating connector |
Sun, 13 Nov, 00:13 |
| j...@apache.org |
kafka git commit: KAFKA-4409; Fix deadlock between topic event handling and shutdown in ZookeeperConsumerConnector |
Mon, 14 Nov, 17:59 |
| j...@apache.org |
[1/5] kafka git commit: KAFKA-2066; Use client-side FetchRequest/FetchResponse on server |
Tue, 15 Nov, 00:46 |
| j...@apache.org |
[2/5] kafka git commit: KAFKA-2066; Use client-side FetchRequest/FetchResponse on server |
Tue, 15 Nov, 00:46 |
| j...@apache.org |
[3/5] kafka git commit: KAFKA-2066; Use client-side FetchRequest/FetchResponse on server |
Tue, 15 Nov, 00:46 |
| j...@apache.org |
[4/5] kafka git commit: KAFKA-2066; Use client-side FetchRequest/FetchResponse on server |
Tue, 15 Nov, 00:46 |
| j...@apache.org |
[5/5] kafka git commit: KAFKA-2066; Use client-side FetchRequest/FetchResponse on server |
Tue, 15 Nov, 00:46 |
| j...@apache.org |
kafka git commit: HOTFIX: Remove failing ConnectDistributedTest.test_bad_connector_class |
Tue, 15 Nov, 01:10 |
| ij...@apache.org |
kafka git commit: MINOR: Clarify how to fix conversion issues when plain JSON data is used with schemas.enable=true |
Tue, 15 Nov, 14:23 |
| j...@apache.org |
kafka git commit: MINOR: Remove unused `ByteBoundedBlockingQueue` class and `zkSessionTimeout` parameter |
Wed, 16 Nov, 17:51 |
| guozh...@apache.org |
kafka git commit: MINOR: add a space to separate two words |
Wed, 16 Nov, 19:36 |
| guozh...@apache.org |
kafka git commit: KAFKA-4359: Remove commit interval in integration tests for testing caching effects |
Wed, 16 Nov, 20:46 |
| j...@apache.org |
kafka git commit: KAFKA-4211; Update system test services to use the new consumer by default |
Thu, 17 Nov, 00:30 |
| ij...@apache.org |
kafka git commit: MINOR: Extract SCALA_BINARY_VERSION from SCALA_VERSION |
Thu, 17 Nov, 02:15 |
| ij...@apache.org |
kafka git commit: KAFKA-4376; Cross compile to Scala 2.12.0 |
Thu, 17 Nov, 03:44 |
| guozh...@apache.org |
kafka git commit: KAFKA-4366: KafkaStreams.close() blocks indefinitely |
Thu, 17 Nov, 20:49 |
| guozh...@apache.org |
kafka git commit: KAFKA-3825: Allow users to specify different types of state stores in Streams DSL |
Thu, 17 Nov, 20:52 |
| ewe...@apache.org |
kafka git commit: KAFKA-4417: Update build dependencies for 0.10.2 cycle |
Thu, 17 Nov, 22:43 |
| gwens...@apache.org |
[1/2] kafka-site git commit: added new meetup links on events page and remove docs subnav on old versions of the docs |
Thu, 17 Nov, 23:47 |
| gwens...@apache.org |
[2/2] kafka-site git commit: remove link to kafka-summit site for now |
Thu, 17 Nov, 23:47 |
| guozh...@apache.org |
kafka git commit: HOTFIX: corrupted commit 10cfc1628df024f7596d3af5c168fa90f59035ca |
Fri, 18 Nov, 00:53 |
| ij...@apache.org |
[1/2] kafka git commit: KAFKA-4377; remove deprecated scala.collection.JavaConversions calls |
Fri, 18 Nov, 13:54 |
| ij...@apache.org |
[2/2] kafka git commit: KAFKA-4377; remove deprecated scala.collection.JavaConversions calls |
Fri, 18 Nov, 13:54 |
| ij...@apache.org |
kafka git commit: KAFKA-4420; Group StopReplicaRequests for partitions on the same broker into one StopReplicaRequest |
Sat, 19 Nov, 01:27 |
| ij...@apache.org |
kafka git commit: KAFKA-3703; Graceful close for consumers and producer with acks=0 |
Sat, 19 Nov, 09:34 |
| ij...@apache.org |
kafka git commit: HOTFIX: Hotfix streams smoke test |
Sat, 19 Nov, 09:38 |
| ij...@apache.org |
kafka git commit: HOTFIX: Increased wait time |
Mon, 21 Nov, 14:25 |
| ij...@apache.org |
kafka git commit: MINOR: Typo in KafkaConsumer javadoc |
Tue, 22 Nov, 11:29 |
| guozh...@apache.org |
kafka git commit: KAFKA-4355: Skip topics that have no partitions |
Tue, 22 Nov, 17:54 |
| j...@apache.org |
kafka git commit: KAFKA-4362; Consumer can fail after reassignment of the offsets topic partition |
Wed, 23 Nov, 04:33 |
| j...@apache.org |
kafka git commit: KAFKA-4362; Consumer can fail after reassignment of the offsets topic partition |
Wed, 23 Nov, 04:35 |
| ij...@apache.org |
kafka git commit: KAFKA-4395; Break static initialization order dependency between KafkaConfig and Logconfig |
Wed, 23 Nov, 11:06 |
| ij...@apache.org |
kafka git commit: KAFKA-4395; Break static initialization order dependency between KafkaConfig and Logconfig |
Wed, 23 Nov, 11:06 |
| guozh...@apache.org |
[1/5] kafka git commit: HOTFIX: Fix putAll and putIfAbsent logic for correct eviction behavior |
Wed, 23 Nov, 15:28 |
| guozh...@apache.org |
[2/5] kafka git commit: HOTFIX: follow up on KAFKA-4275 |
Wed, 23 Nov, 15:28 |
| guozh...@apache.org |
[3/5] kafka git commit: KAFKA-4331: Kafka Streams resetter is slow because it joins the same group for each topic |
Wed, 23 Nov, 15:28 |
| guozh...@apache.org |
[4/5] kafka git commit: MINOR: improve JavaDoc for Streams window retention time |
Wed, 23 Nov, 15:28 |
| guozh...@apache.org |
[5/5] kafka git commit: KAFKA-4361: Streams does not respect user configs for "default" params |
Wed, 23 Nov, 15:28 |
| guozh...@apache.org |
kafka git commit: KAFKA-4331: Kafka Streams resetter is slow because it joins the same group for each topic |
Thu, 24 Nov, 01:31 |
| guozh...@apache.org |
kafka git commit: KAFKA-4331: Kafka Streams resetter is slow because it joins the same group for each topic |
Thu, 24 Nov, 01:36 |
| srihar...@apache.org |
[1/4] kafka git commit: KAFKA-4345; Run decktape test for each pull request |
Thu, 24 Nov, 04:49 |
| srihar...@apache.org |
[2/4] kafka git commit: KAFKA-4345; Run decktape test for each pull request |
Thu, 24 Nov, 04:49 |
| srihar...@apache.org |
[3/4] kafka git commit: KAFKA-4345; Run decktape test for each pull request |
Thu, 24 Nov, 04:49 |
| srihar...@apache.org |
[4/4] kafka git commit: KAFKA-4345; Run decktape test for each pull request |
Thu, 24 Nov, 04:49 |
| guozh...@apache.org |
[kafka] Git Push Summary [forced push!] [Forced Update!] |
Thu, 24 Nov, 05:06 |
| guozh...@apache.org |
[1/4] kafka git commit: KAFKA-4311: Multi layer cache eviction causes forwarding to incorrect ProcessorNode |
Thu, 24 Nov, 05:10 |
| guozh...@apache.org |
[2/4] kafka git commit: MINOR: fix incorrect logging in StreamThread |
Thu, 24 Nov, 05:10 |
| guozh...@apache.org |
[3/4] kafka git commit: KAFKA-4379: Remove caching of dirty and removed keys from StoreChangeLogger |
Thu, 24 Nov, 05:10 |
| guozh...@apache.org |
[4/4] kafka git commit: KAFKA-4331: Kafka Streams resetter is slow because it joins the same group for each topic |
Thu, 24 Nov, 05:10 |
| guozh...@apache.org |
kafka git commit: Cherry-pick KAFKA-4355: Skip topics that have no partitions, by Eno Thereska |
Thu, 24 Nov, 05:34 |
| ij...@apache.org |
kafka git commit: KAFKA-4384; ReplicaFetcherThread stops after ReplicaFetcherThread receives a corrupted message |
Thu, 24 Nov, 14:51 |
| ij...@apache.org |
kafka git commit: KAFKA-4384; ReplicaFetcherThread stops after ReplicaFetcherThread receives a corrupted message |
Thu, 24 Nov, 14:52 |
| ewe...@apache.org |
[1/4] kafka git commit: Revert "KAFKA-4345; Run decktape test for each pull request" |
Tue, 29 Nov, 17:11 |
| ewe...@apache.org |
[2/4] kafka git commit: Revert "KAFKA-4345; Run decktape test for each pull request" |
Tue, 29 Nov, 17:11 |
| ewe...@apache.org |
[3/4] kafka git commit: Revert "KAFKA-4345; Run decktape test for each pull request" |
Tue, 29 Nov, 17:11 |
| ewe...@apache.org |
[4/4] kafka git commit: Revert "KAFKA-4345; Run decktape test for each pull request" |
Tue, 29 Nov, 17:11 |
| ewe...@apache.org |
kafka git commit: MINOR: doc fix related to monitoring consumer lag |
Tue, 29 Nov, 17:57 |
| j...@apache.org |
kafka git commit: KAFKA-4443; Controller should send UpdateMetadataRequest prior to LeaderAndIsrRequest during failover |
Tue, 29 Nov, 18:03 |
| ewe...@apache.org |
kafka git commit: MINOR: Remove unused code in `LeaderAndIsr`, `ApiUtils` and `TopicMetadataRequest` |
Tue, 29 Nov, 18:32 |
| guozh...@apache.org |
kafka git commit: KAFKA-4427: Skip topic groups with no tasks |
Tue, 29 Nov, 19:07 |
| ewe...@apache.org |
kafka git commit: MINOR: Make release notes script check resolutions to avoid spurious inclusion of non-fix 'fixes' in release notes. |
Tue, 29 Nov, 19:36 |