| ewe...@apache.org |
kafka git commit: KAFKA-2667; Fix assertion depending on hash map order in KafkaBasedLogTest.testSendAndReadToEnd |
Wed, 09 Dec, 01:49 |
| ewe...@apache.org |
kafka-site git commit: Add Ewen as committer. |
Wed, 09 Dec, 05:25 |
| ewe...@apache.org |
kafka git commit: KAFKA-2578; Client Metadata internal state should be synchronized |
Thu, 10 Dec, 18:02 |
| ewe...@apache.org |
kafka git commit: KAFKA-2578; Client Metadata internal state should be synchronized |
Thu, 10 Dec, 18:02 |
| ewe...@apache.org |
kafka git commit: KAFKA-2926; [MirrorMaker] InternalRebalancer calls wrong method of external rebalancer |
Thu, 10 Dec, 21:09 |
| ewe...@apache.org |
kafka git commit: KAFKA-2926; [MirrorMaker] InternalRebalancer calls wrong method of external rebalancer |
Thu, 10 Dec, 21:10 |
| ewe...@apache.org |
kafka git commit: KAFKA-2928; system test: fix version sanity checks |
Thu, 10 Dec, 23:27 |
| ewe...@apache.org |
kafka git commit: KAFKA-2896; Added system test for partition re-assignment |
Fri, 11 Dec, 01:07 |
| ewe...@apache.org |
kafka git commit: KAFKA-2927; reduce system test storage footprint |
Fri, 11 Dec, 01:35 |
| ewe...@apache.org |
kafka git commit: MINOR: Change SaslSetup workDir to be under the build folder |
Fri, 11 Dec, 04:46 |
| ewe...@apache.org |
kafka git commit: KAFKA-2070; Replace Offset{Request,Response} with o.a.k.c requests equivalent |
Fri, 11 Dec, 17:37 |
| ewe...@apache.org |
kafka git commit: KAFKA-2990; Fix NoSuchMethodError in Pool with cast to ConcurrentMap |
Tue, 15 Dec, 00:02 |
| ewe...@apache.org |
kafka git commit: KAFKA-2990; Fix NoSuchMethodError in Pool with cast to ConcurrentMap |
Tue, 15 Dec, 00:02 |
| ewe...@apache.org |
kafka git commit: MINOR: Documentation updates for reserved.broker.max.id |
Tue, 15 Dec, 03:13 |
| ewe...@apache.org |
kafka git commit: MINOR: Documentation updates for reserved.broker.max.id |
Tue, 15 Dec, 03:13 |
| ewe...@apache.org |
kafka git commit: MINOR: Updating comment that fell out of sync with code |
Wed, 16 Dec, 00:18 |
| ewe...@apache.org |
kafka git commit: MINOR: Add information to upgrade notes |
Wed, 16 Dec, 04:57 |
| ewe...@apache.org |
kafka git commit: MINOR: Add information to upgrade notes |
Wed, 16 Dec, 04:58 |
| ewe...@apache.org |
kafka git commit: MINOR: Change return type of `Schema.read` to be `Struct` instead of `Object` |
Fri, 18 Dec, 18:27 |
| ewe...@apache.org |
kafka git commit: KAFKA-3009; Disallow star imports |
Mon, 21 Dec, 21:31 |
| ewe...@apache.org |
kafka git commit: KAFKA-3020; Ensure CheckStyle runs on all Java code |
Tue, 22 Dec, 06:58 |
| ewe...@apache.org |
kafka git commit: KAFKA-2989; System tests should verify partitions consumed after rebalancing |
Wed, 23 Dec, 00:15 |
| ewe...@apache.org |
kafka git commit: MINOR: Use "new line" delimeters in a portable way in a unit test |
Wed, 23 Dec, 01:07 |
| ewe...@apache.org |
kafka git commit: KAFKA-3002; Allow uppercase letters in hostnames |
Thu, 24 Dec, 04:56 |
| ewe...@apache.org |
kafka git commit: KAFKA-3002; Allow uppercase letters in hostnames |
Thu, 24 Dec, 04:56 |
| ewe...@apache.org |
kafka git commit: MINOR: Update to Gradle 2.10 |
Fri, 25 Dec, 19:40 |
| guozh...@apache.org |
kafka git commit: KAFKA-2913: missing partition check when removing groups from cache |
Tue, 01 Dec, 05:33 |
| guozh...@apache.org |
kafka git commit: KAFKA-2913: missing partition check when removing groups from cache |
Tue, 01 Dec, 05:33 |
| guozh...@apache.org |
kafka git commit: MINOR: Update "Java Version" section |
Tue, 01 Dec, 19:15 |
| guozh...@apache.org |
kafka git commit: MINOR: Update LinkedIn JVM tuning settings |
Tue, 01 Dec, 19:16 |
| guozh...@apache.org |
kafka git commit: MINOR: Update LinkedIn JVM tuning settings |
Tue, 01 Dec, 19:16 |
| guozh...@apache.org |
kafka-site git commit: Update JVM version and tuning settings |
Tue, 01 Dec, 19:21 |
| guozh...@apache.org |
kafka git commit: KAFKA-2915: Fix problem with System Tests that use bootstrap.servers embedded in jinja files |
Tue, 01 Dec, 19:48 |
| guozh...@apache.org |
kafka git commit: MINOR - fix typo in index corruption warning message |
Tue, 01 Dec, 19:50 |
| guozh...@apache.org |
kafka git commit: MINOR - fix typo in index corruption warning message |
Tue, 01 Dec, 19:50 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix building from subproject directory |
Tue, 01 Dec, 19:52 |
| guozh...@apache.org |
kafka git commit: KAFKA-2421: Upgrade LZ4 to version 1.3 |
Tue, 01 Dec, 19:57 |
| guozh...@apache.org |
kafka git commit: KAFKA-2851 Using random file names for local kdc files to avoid conflicts. |
Wed, 02 Dec, 19:17 |
| guozh...@apache.org |
kafka git commit: KAFKA-2880: consumer should handle disconnect/timeout for metadata requests |
Wed, 02 Dec, 19:27 |
| guozh...@apache.org |
kafka git commit: KAFKA-2880: consumer should handle disconnect/timeout for metadata requests |
Wed, 02 Dec, 19:27 |
| guozh...@apache.org |
kafka git commit: KAFKA-2902: streaming config use get base consumer configs. |
Thu, 03 Dec, 02:40 |
| guozh...@apache.org |
kafka git commit: Manually ported changes in 8c3c9548b636cdf760d2537afe115942d13bc003 to 0.9.0 (no cherry-pick due to conflicts) |
Thu, 03 Dec, 16:41 |
| guozh...@apache.org |
kafka git commit: MINOR: ConsoleConsumer - Fix number of processed messages count |
Thu, 03 Dec, 16:58 |
| guozh...@apache.org |
kafka git commit: MINOR: ConsoleConsumer - Fix number of processed messages count |
Thu, 03 Dec, 16:58 |
| guozh...@apache.org |
kafka git commit: KAFKA-2825: Add controller failover to existing replication tests |
Thu, 03 Dec, 18:43 |
| guozh...@apache.org |
kafka git commit: KAFKA-2942: inadvertent auto-commit when pre-fetching can cause message loss |
Thu, 03 Dec, 19:01 |
| guozh...@apache.org |
kafka git commit: KAFKA-2942: inadvertent auto-commit when pre-fetching can cause message loss |
Thu, 03 Dec, 19:01 |
| guozh...@apache.org |
kafka git commit: KAFKA-2905: System test for rolling upgrade to enable ZooKeeper ACLs with SASL |
Fri, 04 Dec, 01:47 |
| guozh...@apache.org |
kafka git commit: KAFKA-2931: add system test for consumer rolling upgrades |
Fri, 04 Dec, 05:17 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-2856: Add KTable non-stateful APIs along with standby task support |
Fri, 04 Dec, 22:59 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-2856: Add KTable non-stateful APIs along with standby task support |
Fri, 04 Dec, 22:59 |
| guozh...@apache.org |
kafka git commit: KAFKA-2950: Fix performance regression in the producer |
Sat, 05 Dec, 23:57 |
| guozh...@apache.org |
kafka git commit: KAFKA-2950: Fix performance regression in the producer |
Sat, 05 Dec, 23:57 |
| guozh...@apache.org |
kafka git commit: MINOR: Remove unused DoublyLinkedList |
Tue, 08 Dec, 07:15 |
| guozh...@apache.org |
kafka git commit: MINOR: Remove unused DoublyLinkedList |
Tue, 08 Dec, 07:15 |
| guozh...@apache.org |
kafka git commit: HOTFIX: fix ProcessorStateManager to use correct ktable partitions |
Tue, 08 Dec, 07:16 |
| guozh...@apache.org |
kafka git commit: KAFKA-2924: support offsets topic in DumpLogSegments |
Wed, 09 Dec, 05:48 |
| guozh...@apache.org |
kafka git commit: KAFKA-2924: support offsets topic in DumpLogSegments |
Wed, 09 Dec, 05:48 |
| guozh...@apache.org |
kafka git commit: KAFKA-2962: stream-table table-table joins |
Wed, 09 Dec, 07:33 |
| guozh...@apache.org |
kafka git commit: Minor: Fix @link in MetricName comment |
Wed, 09 Dec, 18:59 |
| guozh...@apache.org |
kafka git commit: KAFKA-2972; Add missing `partitionsRemaingList.add` in `ControlledShutdownResponse` constructor |
Wed, 09 Dec, 19:57 |
| guozh...@apache.org |
kafka git commit: KAFKA-2972; Add missing `partitionsRemaingList.add` in `ControlledShutdownResponse` constructor |
Wed, 09 Dec, 19:57 |
| guozh...@apache.org |
kafka git commit: KAFKA-2974; `==` is used incorrectly in a few places in Java code |
Thu, 10 Dec, 04:34 |
| guozh...@apache.org |
kafka git commit: KAFKA-2974; `==` is used incorrectly in a few places in Java code |
Thu, 10 Dec, 04:35 |
| guozh...@apache.org |
kafka git commit: KAFKA-2733: Standardize metric name for Kafka Streams |
Thu, 10 Dec, 06:15 |
| guozh...@apache.org |
kafka git commit: HOTFIX: fix table-table outer join and left join. more tests |
Thu, 10 Dec, 07:02 |
| guozh...@apache.org |
kafka git commit: KAFKA-2893: Add a simple non-negative partition seek check |
Thu, 10 Dec, 18:49 |
| guozh...@apache.org |
kafka git commit: KAFKA-2893: Add a simple non-negative partition seek check |
Thu, 10 Dec, 18:49 |
| guozh...@apache.org |
kafka git commit: MINOR: test ktable state store creation |
Fri, 11 Dec, 05:48 |
| guozh...@apache.org |
kafka git commit: KAFKA-2981: Fix javadoc in KafkaConsumer |
Fri, 11 Dec, 19:32 |
| guozh...@apache.org |
kafka git commit: KAFKA-2981: Fix javadoc in KafkaConsumer |
Fri, 11 Dec, 19:32 |
| guozh...@apache.org |
kafka git commit: KAFKA-2837: Fix transient failure of kafka.api.ProducerBounceTest.testBrokerFailure |
Sun, 13 Dec, 19:51 |
| guozh...@apache.org |
kafka git commit: KAFKA-2978: consumer stops fetching when consumed and fetch positions get out of sync |
Mon, 14 Dec, 22:54 |
| guozh...@apache.org |
kafka git commit: KAFKA-2978: consumer stops fetching when consumed and fetch positions get out of sync |
Mon, 14 Dec, 22:54 |
| guozh...@apache.org |
kafka git commit: KAFKA-2837 Follow-up: Default max block to 60 seconds |
Tue, 15 Dec, 01:52 |
| guozh...@apache.org |
kafka git commit: MINOR: StreamThread performance optimization |
Wed, 16 Dec, 07:53 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-2984: KTable should send old values when required |
Wed, 16 Dec, 23:37 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-2984: KTable should send old values when required |
Wed, 16 Dec, 23:37 |
| guozh...@apache.org |
kafka git commit: KAFKA-2058: Fix ProducerTest.testSendWithDeadBroker transient failure |
Mon, 21 Dec, 06:01 |
| guozh...@apache.org |
kafka git commit: KAFKA-2058: Fix ProducerTest.testSendWithDeadBroker transient failure |
Mon, 21 Dec, 06:01 |
| guozh...@apache.org |
kafka git commit: KAFKA-2977: Transient Failure in kafka.log.LogCleanerIntegrationTest.cleanerTest |
Mon, 21 Dec, 06:07 |
| guozh...@apache.org |
kafka git commit: KAFKA-2977: Transient Failure in kafka.log.LogCleanerIntegrationTest.cleanerTest |
Mon, 21 Dec, 06:07 |
| guozh...@apache.org |
kafka git commit: KAFKA-2455: Fix failure in kafka.consumer.MetricsTest.testMetricsLeak |
Mon, 21 Dec, 18:44 |
| guozh...@apache.org |
kafka git commit: KAFKA-2455: Fix failure in kafka.consumer.MetricsTest.testMetricsLeak |
Mon, 21 Dec, 18:44 |
| guozh...@apache.org |
kafka git commit: KAFKA-3014: fix integer overflow problem in leastLoadedNode |
Mon, 21 Dec, 18:53 |
| guozh...@apache.org |
kafka git commit: KAFKA-3014: fix integer overflow problem in leastLoadedNode |
Mon, 21 Dec, 18:54 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix typo in documentation |
Tue, 22 Dec, 18:44 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix typo in documentation |
Tue, 22 Dec, 18:44 |
| gwens...@apache.org |
kafka git commit: MINOR: backport fix to partition assignor order (KAFKA-2931) |
Sat, 05 Dec, 22:06 |
| gwens...@apache.org |
[1/2] kafka git commit: KAFKA-2804: manage changelog topics through ZK in PartitionAssignor |
Mon, 07 Dec, 23:12 |
| gwens...@apache.org |
[2/2] kafka git commit: KAFKA-2804: manage changelog topics through ZK in PartitionAssignor |
Mon, 07 Dec, 23:12 |
| gwens...@apache.org |
kafka git commit: KAFKA-2958: Remove duplicate API key mapping functionality |
Tue, 08 Dec, 17:55 |
| gwens...@apache.org |
kafka git commit: KAFKA-2957: Fix typos in Kafka documentation |
Tue, 08 Dec, 20:56 |
| gwens...@apache.org |
kafka git commit: KAFKA-2957: Fix typos in Kafka documentation |
Tue, 08 Dec, 20:56 |
| gwens...@apache.org |
kafka git commit: MINOR: Use `EasyMock.newCapture` instead of deprecated `new Capture` |
Wed, 09 Dec, 01:21 |
| gwens...@apache.org |
kafka git commit: KAFKA-2399; Replace `Stream.continually` with `Iterator.continually` |
Wed, 09 Dec, 01:22 |
| gwens...@apache.org |
kafka git commit: KAFKA-2973; Fix leak of child sensors on remove |
Wed, 09 Dec, 17:52 |
| gwens...@apache.org |
kafka git commit: KAFKA-2973; Fix leak of child sensors on remove |
Wed, 09 Dec, 17:52 |
| gwens...@apache.org |
kafka git commit: KAFKA-2965; Two variables should be exchanged. |
Wed, 09 Dec, 18:02 |
| gwens...@apache.org |
kafka git commit: MINOR: Trivial doc/ typo fixes. |
Wed, 09 Dec, 23:39 |