| ewe...@apache.org |
kafka git commit: KAFKA-4077: Backdate system test certificates to cope with clock skew |
Thu, 01 Sep, 17:05 |
| ewe...@apache.org |
kafka git commit: KAFKA-4162: Fixed typo "rebalance" |
Wed, 14 Sep, 17:38 |
| ewe...@apache.org |
kafka git commit: KAFKA-4162: Fixed typo "rebalance" |
Wed, 14 Sep, 17:38 |
| ewe...@apache.org |
kafka git commit: MINOR: Wakeups propagated from commitOffsets in WorkerSinkTask should be caught |
Mon, 26 Sep, 21:54 |
| ewe...@apache.org |
kafka git commit: MINOR: Wakeups propagated from commitOffsets in WorkerSinkTask should be caught |
Mon, 26 Sep, 21:54 |
| guozh...@apache.org |
kafka git commit: KAFKA-4112: Remove alpha quality label from Kafka Streams in docs |
Thu, 01 Sep, 19:21 |
| guozh...@apache.org |
kafka git commit: KAFKA-4112: Remove alpha quality label from Kafka Streams in docs |
Thu, 01 Sep, 19:25 |
| guozh...@apache.org |
kafka git commit: KAFKA-4104: Queryable state metadata is sometimes invalid |
Fri, 02 Sep, 04:21 |
| guozh...@apache.org |
kafka git commit: KAFKA-4105: Queryable state tests |
Mon, 05 Sep, 04:49 |
| guozh...@apache.org |
kafka git commit: KAFKA-4023: Add thread id and task id for logging prefix in Streams |
Tue, 06 Sep, 18:38 |
| guozh...@apache.org |
[1/2] kafka git commit: MINOR: changes embedded broker time to MockTime |
Tue, 06 Sep, 22:35 |
| guozh...@apache.org |
[2/2] kafka git commit: MINOR: changes embedded broker time to MockTime |
Tue, 06 Sep, 22:35 |
| guozh...@apache.org |
kafka git commit: KAFKA-4058: Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset |
Wed, 07 Sep, 06:02 |
| guozh...@apache.org |
kafka git commit: MINOR: Fixes javadoc of Windows, fixes typo in parameter name of KGroupedTable |
Wed, 07 Sep, 22:28 |
| guozh...@apache.org |
kafka git commit: KAFKA-4123: Queryable State returning null for key before all stores in instance have been initialized |
Thu, 08 Sep, 00:42 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-3595: window stores use compact, delete config for changelogs |
Thu, 08 Sep, 01:02 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-3595: window stores use compact, delete config for changelogs |
Thu, 08 Sep, 01:02 |
| guozh...@apache.org |
kafka git commit: MINOR: fix transient QueryableStateIntegration test failure |
Thu, 08 Sep, 17:53 |
| guozh...@apache.org |
kafka git commit: MINOR: catch InvalidStateStoreException in QueryableStateIntegrationTest |
Mon, 12 Sep, 04:00 |
| guozh...@apache.org |
kafka git commit: KAFKA-4160: Ensure rebalance listener not called with coordinator lock |
Thu, 15 Sep, 05:31 |
| guozh...@apache.org |
kafka git commit: HOTFIX: set sourceNodes to null for selectKey |
Thu, 15 Sep, 15:42 |
| guozh...@apache.org |
kafka git commit: HOTFIX: fix KafkaStreams SmokeTest |
Thu, 15 Sep, 15:57 |
| guozh...@apache.org |
kafka git commit: KAFKA-4131; Multiple Regex KStream-Consumers cause Null pointer exception |
Fri, 16 Sep, 00:08 |
| guozh...@apache.org |
[1/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams |
Fri, 16 Sep, 16:58 |
| guozh...@apache.org |
[2/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams |
Fri, 16 Sep, 16:58 |
| guozh...@apache.org |
[3/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams |
Fri, 16 Sep, 16:58 |
| guozh...@apache.org |
[4/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams |
Fri, 16 Sep, 16:58 |
| guozh...@apache.org |
[5/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams |
Fri, 16 Sep, 16:58 |
| guozh...@apache.org |
[6/6] kafka git commit: KAFKA-3776: Unify store and downstream caching in streams |
Fri, 16 Sep, 16:58 |
| guozh...@apache.org |
kafka git commit: HOTFIX: logic in QuerybaleStateIntegrationTest.shouldBeAbleToQueryState incorrect |
Mon, 19 Sep, 17:29 |
| guozh...@apache.org |
kafka git commit: KAFKA-4175: Can't have StandbyTasks in KafkaStreams where NUM_STREAM_THREADS_CONFIG > 1 |
Mon, 19 Sep, 17:31 |
| guozh...@apache.org |
kafka git commit: KAFKA-4163: NPE in StreamsMetadataState during re-balance operations |
Mon, 19 Sep, 18:00 |
| guozh...@apache.org |
kafka git commit: MINOR: Allow creation of statestore without logging enabled or explicit source topic |
Mon, 19 Sep, 19:37 |
| guozh...@apache.org |
kafka git commit: KAFKA-4153: Fix incorrect KStream-KStream join behavior with asymmetric time window |
Tue, 20 Sep, 00:13 |
| guozh...@apache.org |
kafka git commit: MINOR: add javadoc comment to PersistenKeyValueFactory.enableCaching |
Wed, 21 Sep, 18:11 |
| guozh...@apache.org |
kafka git commit: MINOR: add javadoc comment to PersistenKeyValueFactory.enableCaching |
Wed, 21 Sep, 18:11 |
| guozh...@apache.org |
kafka git commit: MINOR: remove unused code from InternalTopicManager |
Wed, 21 Sep, 18:13 |
| guozh...@apache.org |
kafka git commit: MINOR: remove unused code from InternalTopicManager |
Wed, 21 Sep, 18:13 |
| guozh...@apache.org |
kafka git commit: KAFKA-3782: Ensure heartbeat thread restarted after rebalance woken up |
Thu, 22 Sep, 17:07 |
| guozh...@apache.org |
kafka git commit: KAFKA-3782: Ensure heartbeat thread restarted after rebalance woken up |
Thu, 22 Sep, 17:08 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix comments in KStreamKStreamJoinTest |
Thu, 22 Sep, 17:33 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix comments in KStreamKStreamJoinTest |
Thu, 22 Sep, 17:33 |
| guozh...@apache.org |
kafka git commit: HOTFIX: Decrease commit interval |
Thu, 22 Sep, 19:45 |
| guozh...@apache.org |
kafka git commit: HOTFIX: Decrease commit interval |
Thu, 22 Sep, 19:45 |
| guozh...@apache.org |
kafka git commit: HOTFIX: fix npe in StreamsMetadataState when onChange has not been called |
Wed, 28 Sep, 00:35 |
| guozh...@apache.org |
kafka git commit: HOTFIX: fix npe in StreamsMetadataState when onChange has not been called |
Wed, 28 Sep, 00:35 |
| guozh...@apache.org |
kafka git commit: MINOR: fixes a few error logging formats |
Wed, 28 Sep, 00:37 |
| guozh...@apache.org |
kafka git commit: MINOR: fixes a few error logging formats |
Wed, 28 Sep, 00:37 |
| guozh...@apache.org |
kafka git commit: MINOR: add test to make sure ProcessorStateManager can handle State Stores with logging disabled |
Wed, 28 Sep, 00:43 |
| guozh...@apache.org |
kafka git commit: MINOR: add test to make sure ProcessorStateManager can handle State Stores with logging disabled |
Wed, 28 Sep, 00:43 |
| guozh...@apache.org |
kafka git commit: KAFKA-3708: Better exception handling in Kafka Streams |
Wed, 28 Sep, 18:07 |
| guozh...@apache.org |
kafka git commit: KAFKA-3708: Better exception handling in Kafka Streams |
Wed, 28 Sep, 18:07 |
| guozh...@apache.org |
kafka git commit: HOTFIX: do not call partitioner if num partitions is non-positive |
Fri, 30 Sep, 16:36 |
| guozh...@apache.org |
kafka git commit: HOTFIX: do not call partitioner if num partitions is non-positive |
Fri, 30 Sep, 16:36 |
| guozh...@apache.org |
kafka git commit: KAFKA-4233: StateDirectory fails to create directory if any parent directory does not exist |
Fri, 30 Sep, 18:55 |
| guozh...@apache.org |
kafka git commit: KAFKA-4233: StateDirectory fails to create directory if any parent directory does not exist |
Fri, 30 Sep, 18:56 |
| gwens...@apache.org |
kafka git commit: MINOR: More graceful handling of buffers that are too small in Record's `isValid` and `ensureValid` |
Wed, 07 Sep, 00:34 |
| gwens...@apache.org |
[1/2] kafka-site git commit: Try to include streams and connect better. Removing messaging centric terminology. Rewrite introduction page. Make a linked doc sections stand alone. |
Thu, 29 Sep, 00:33 |
| gwens...@apache.org |
[2/2] kafka-site git commit: Try to include streams and connect better. Removing messaging centric terminology. Rewrite introduction page. Make a linked doc sections stand alone. |
Thu, 29 Sep, 00:33 |
| ij...@apache.org |
kafka git commit: MINOR: Include TopicPartition in warning when log cleaner resets dirty offset |
Wed, 07 Sep, 00:16 |
| ij...@apache.org |
kafka git commit: KAFKA-4129; Processor throw exception when getting channel remote address after closing the channel |
Wed, 07 Sep, 00:17 |
| ij...@apache.org |
kafka git commit: MINOR: Reduce the log level when the peer isn't authenticated but is using SSL |
Wed, 07 Sep, 02:43 |
| ij...@apache.org |
kafka git commit: KAFKA-3129; Console producer issue when request-required-acks=0 |
Wed, 07 Sep, 16:08 |
| ij...@apache.org |
kafka git commit: HOTFIX: Temporarily ignoring this test until fixed |
Fri, 09 Sep, 14:22 |
| ij...@apache.org |
kafka git commit: KAFKA-3807; Fix transient test failure caused by race on future completion |
Fri, 09 Sep, 21:08 |
| ij...@apache.org |
kafka git commit: KAFKA-4145; Avoid redundant integration testing in ProducerSendTests |
Sat, 10 Sep, 07:16 |
| ij...@apache.org |
kafka git commit: KAFKA-4147; Fix transient failure in ConsumerCoordinatorTest.testAutoCommitDynamicAssignment |
Sun, 11 Sep, 07:46 |
| ij...@apache.org |
[1/2] kafka git commit: KAFKA-4093; Cluster Id (KIP-78) |
Sat, 17 Sep, 07:13 |
| ij...@apache.org |
[2/2] kafka git commit: KAFKA-4093; Cluster Id (KIP-78) |
Sat, 17 Sep, 07:13 |
| ij...@apache.org |
kafka git commit: HOTFIX: Increase timeout for bounce test |
Sat, 17 Sep, 21:43 |
| ij...@apache.org |
kafka git commit: HOTFIX: changed quickstart donwload from 0.10.0.0 to 0.10.0.1 |
Sat, 17 Sep, 21:45 |
| ij...@apache.org |
kafka git commit: HOTFIX: changed quickstart donwload from 0.10.0.0 to 0.10.0.1 |
Sat, 17 Sep, 21:45 |
| ij...@apache.org |
kafka git commit: KAFKA-4157; Transient system test failure in replica_verification_test.test_replica_lags |
Sat, 17 Sep, 21:48 |
| ij...@apache.org |
kafka git commit: KAFKA-4157; Transient system test failure in replica_verification_test.test_replica_lags |
Sat, 17 Sep, 21:48 |
| ij...@apache.org |
kafka git commit: MINOR: Update the README.md to include a note about GRADLE_USER_HOME |
Sat, 17 Sep, 22:01 |
| ij...@apache.org |
kafka git commit: MINOR: Fix reference to argument in `LogSegment.translateOffset` |
Sun, 18 Sep, 22:01 |
| ij...@apache.org |
kafka git commit: HOTFIX: Added check for metadata unavailable |
Tue, 20 Sep, 10:39 |
| ij...@apache.org |
kafka git commit: HOTFIX: Added check for metadata unavailable |
Tue, 20 Sep, 10:40 |
| ij...@apache.org |
kafka git commit: KAFKA-4184; Intermittent failures in ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle |
Tue, 20 Sep, 14:39 |
| ij...@apache.org |
kafka git commit: KAFKA-4184; Intermittent failures in ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle |
Tue, 20 Sep, 14:39 |
| ij...@apache.org |
kafka git commit: KAFKA-4197; Make ReassignPartitionsTest System Test move data |
Tue, 20 Sep, 14:41 |
| ij...@apache.org |
kafka git commit: KAFKA-4197; Make ReassignPartitionsTest System Test move data |
Tue, 20 Sep, 14:41 |
| ij...@apache.org |
kafka git commit: MINOR: Add test cases for delays in consumer rebalance listener |
Thu, 22 Sep, 22:03 |
| ij...@apache.org |
kafka git commit: KAFKA-3719; Allow underscores in hostname |
Fri, 23 Sep, 21:22 |
| ij...@apache.org |
kafka git commit: KAFKA-3719; Allow underscores in hostname |
Fri, 23 Sep, 21:22 |
| ij...@apache.org |
kafka git commit: KAFKA-4151; Update public docs for Cluster Id (KIP-78) |
Sat, 24 Sep, 09:23 |
| ij...@apache.org |
kafka git commit: KAFKA-4151; Update public docs for Cluster Id (KIP-78) |
Sat, 24 Sep, 09:23 |
| ij...@apache.org |
kafka git commit: KAFKA-3282; Change tools to use new consumer if zookeeper is not specified |
Sun, 25 Sep, 08:14 |
| ij...@apache.org |
kafka git commit: KAFKA-3282; Change tools to use new consumer if zookeeper is not specified |
Sun, 25 Sep, 08:14 |
| ij...@apache.org |
kafka git commit: KAFKA-4200; Fix throttle argument in kafka-reassign-partitions.sh |
Tue, 27 Sep, 13:33 |
| ij...@apache.org |
kafka git commit: KAFKA-4200; Fix throttle argument in kafka-reassign-partitions.sh |
Tue, 27 Sep, 13:34 |
| ij...@apache.org |
kafka git commit: KAFKA-4177; Remove ThrottledReplicationRateLimit from Server Config |
Tue, 27 Sep, 19:40 |
| ij...@apache.org |
kafka git commit: KAFKA-4177; Remove ThrottledReplicationRateLimit from Server Config |
Tue, 27 Sep, 19:41 |
| ij...@apache.org |
kafka git commit: MINOR: Make new consumer default for Mirror Maker |
Tue, 27 Sep, 21:08 |
| ij...@apache.org |
kafka git commit: MINOR: Make new consumer default for Mirror Maker |
Tue, 27 Sep, 21:08 |
| ij...@apache.org |
kafka git commit: HOTFIX: Remove git conflict markers in streams.html |
Wed, 28 Sep, 01:32 |
| ij...@apache.org |
kafka git commit: KAFKA-4227; Shutdown AdminManager when KafkaServer is shutdown |
Wed, 28 Sep, 19:54 |
| ij...@apache.org |
kafka git commit: KAFKA-4227; Shutdown AdminManager when KafkaServer is shutdown |
Wed, 28 Sep, 19:55 |
| ij...@apache.org |
kafka git commit: KAFKA-4209; Reduce run time for quota integration tests |
Thu, 29 Sep, 00:18 |
| ij...@apache.org |
kafka git commit: HOTFIX: Tools for releases prior to 0.10.1 need --new-consumer flag |
Thu, 29 Sep, 06:49 |