ij...@apache.org |
kafka git commit: MINOR: Scala code readability improvements |
Tue, 03 Jan, 11:08 |
ij...@apache.org |
kafka git commit: KAFKA-4318; Migrate ProducerSendTest to the new consumer |
Tue, 03 Jan, 16:08 |
guozh...@apache.org |
kafka git commit: KAFKA-4561; Ordering of operations in StreamThread.shutdownTasksAndState may void at-least-once guarantees |
Tue, 03 Jan, 16:34 |
guozh...@apache.org |
kafka git commit: KAFKA-2434: Remove identical topic subscription constraint for roundrobin strategy in old consumer API |
Tue, 03 Jan, 16:57 |
guozh...@apache.org |
kafka git commit: KAFKA-4528: Fix failure in ProducerTest.testAsyncSendCanCorrectlyFailWithTimeout |
Tue, 03 Jan, 17:11 |
j...@apache.org |
kafka git commit: KAFKA-4404; Add javadocs to document core Connect types, especially that integer types are signed |
Tue, 03 Jan, 19:02 |
j...@apache.org |
kafka git commit: KAFKA-4429; Consumer lag metric should be zero if FetchResponse is empty |
Tue, 03 Jan, 22:11 |
ewe...@apache.org |
kafka git commit: KAFKA-4261: Provide debug option in vagrant-up.sh |
Tue, 03 Jan, 22:47 |
guozh...@apache.org |
kafka-site git commit: HOTFIX: MINOR: Remove duplicate list items. |
Wed, 04 Jan, 02:06 |
j...@apache.org |
[1/2] kafka git commit: MINOR: Improvements to Record related classes (part 1) |
Wed, 04 Jan, 03:53 |
j...@apache.org |
[2/2] kafka git commit: MINOR: Improvements to Record related classes (part 1) |
Wed, 04 Jan, 03:53 |
guozh...@apache.org |
kafka git commit: KAFKA-4584: Fail the 'kafka-configs' command if the config to be removed does not exist |
Wed, 04 Jan, 05:41 |
ij...@apache.org |
kafka git commit: KAFKA-4434; KafkaProducer configuration is logged twice |
Wed, 04 Jan, 09:53 |
ij...@apache.org |
kafka git commit: KAFKA-4583; Fix KafkaConsumerTest.testGracefulClose transient failure |
Wed, 04 Jan, 11:59 |
ij...@apache.org |
kafka git commit: KAFKA-4508; System test that runs client against older versions of the broker |
Wed, 04 Jan, 13:55 |
ij...@apache.org |
kafka git commit: MINOR: Remove stray comma from PartitionInfo.toString |
Thu, 05 Jan, 10:26 |
ij...@apache.org |
kafka git commit: KAFKA-4523; Fix crash during shutdown due to group coordinator attempting to write to a closed log |
Thu, 05 Jan, 11:07 |
ij...@apache.org |
kafka git commit: KAFKA-4523; Fix crash during shutdown due to group coordinator attempting to write to a closed log |
Thu, 05 Jan, 11:07 |
guozh...@apache.org |
kafka git commit: MINOR: Update JavaDoc for KTable helper interfaces |
Thu, 05 Jan, 19:27 |
ewe...@apache.org |
kafka git commit: KAFKA-4575: ensure topic created before starting sink for ConnectDistributedTest.test_pause_resume_sink |
Thu, 05 Jan, 23:22 |
ij...@apache.org |
kafka git commit: MINOR: Add unit tests to the ReassignPartitionsCommand |
Fri, 06 Jan, 11:59 |
guozh...@apache.org |
kafka git commit: MINOR: update JavaDoc for simple helper interfaces of KStream and KTable operators |
Fri, 06 Jan, 16:24 |
guozh...@apache.org |
[1/5] kafka git commit: KAFKA-3452: Support session windows |
Fri, 06 Jan, 18:12 |
guozh...@apache.org |
[2/5] kafka git commit: KAFKA-3452: Support session windows |
Fri, 06 Jan, 18:12 |
guozh...@apache.org |
[3/5] kafka git commit: KAFKA-3452: Support session windows |
Fri, 06 Jan, 18:12 |
guozh...@apache.org |
[4/5] kafka git commit: KAFKA-3452: Support session windows |
Fri, 06 Jan, 18:12 |
guozh...@apache.org |
[5/5] kafka git commit: KAFKA-3452: Support session windows |
Fri, 06 Jan, 18:12 |
guozh...@apache.org |
kafka git commit: MINOR: cleanup Kafka Streams exception classes |
Fri, 06 Jan, 19:48 |
ewe...@apache.org |
kafka git commit: KAFKA-4465: Create docker image and scripts for running tests locally |
Mon, 09 Jan, 00:12 |
ewe...@apache.org |
kafka git commit: KAFKA-4402: make the KafkaProducer true round robin per topic |
Mon, 09 Jan, 04:08 |
guozh...@apache.org |
kafka git commit: KAFKA-4551: StreamsSmokeTest.test_streams intermittent failure |
Mon, 09 Jan, 19:13 |
guozh...@apache.org |
kafka git commit: MINOR: some public JavaDoc cleanup |
Mon, 09 Jan, 23:17 |
guozh...@apache.org |
kafka git commit: MINOR: Maybe decorate inner topics for SourceNode |
Tue, 10 Jan, 04:17 |
ewe...@apache.org |
kafka git commit: TRIVIAL: Fix spelling of log message |
Tue, 10 Jan, 06:12 |
ewe...@apache.org |
kafka git commit: MINOR: Fix small error in javadoc for persistent Stores |
Tue, 10 Jan, 06:53 |
ewe...@apache.org |
kafka git commit: HOTFIX: Convert exception introduced in KAFKA-3637 to warning since clearly it is happening. |
Tue, 10 Jan, 08:01 |
ewe...@apache.org |
kafka git commit: MINOR: Add Replication Quotas Test Rig |
Tue, 10 Jan, 08:43 |
ij...@apache.org |
kafka git commit: MINOR: Remove unnecessary semi-colons |
Tue, 10 Jan, 11:41 |
jun...@apache.org |
[1/2] kafka git commit: KAFKA-3751; SASL/SCRAM implementation |
Tue, 10 Jan, 13:05 |
jun...@apache.org |
[2/2] kafka git commit: KAFKA-3751; SASL/SCRAM implementation |
Tue, 10 Jan, 13:05 |
guozh...@apache.org |
kafka git commit: MINOR: rename SessionStore.findSessionsToMerge to findSessions |
Tue, 10 Jan, 17:38 |
guozh...@apache.org |
kafka git commit: MINOR: Replacing for with foreach loop in stream test classes |
Tue, 10 Jan, 19:53 |
guozh...@apache.org |
[1/2] kafka git commit: KAFKA-4481: relax streams api type contraints |
Wed, 11 Jan, 17:11 |
guozh...@apache.org |
[2/2] kafka git commit: KAFKA-4481: relax streams api type contraints |
Wed, 11 Jan, 17:11 |
guozh...@apache.org |
[1/2] kafka git commit: KAFKA-4060: Remove zk client dependency in kafka streams |
Wed, 11 Jan, 17:15 |
guozh...@apache.org |
[2/2] kafka git commit: KAFKA-4060: Remove zk client dependency in kafka streams |
Wed, 11 Jan, 17:15 |
guozh...@apache.org |
kafka git commit: MINOR: Update rocksDB dependency to 5.0.1 |
Wed, 11 Jan, 17:37 |
ij...@apache.org |
[1/5] kafka git commit: KAFKA-4507; Clients should support older brokers (KIP-97) |
Wed, 11 Jan, 19:31 |
ij...@apache.org |
[2/5] kafka git commit: KAFKA-4507; Clients should support older brokers (KIP-97) |
Wed, 11 Jan, 19:31 |
ij...@apache.org |
[3/5] kafka git commit: KAFKA-4507; Clients should support older brokers (KIP-97) |
Wed, 11 Jan, 19:31 |
ij...@apache.org |
[4/5] kafka git commit: KAFKA-4507; Clients should support older brokers (KIP-97) |
Wed, 11 Jan, 19:31 |
ij...@apache.org |
[5/5] kafka git commit: KAFKA-4507; Clients should support older brokers (KIP-97) |
Wed, 11 Jan, 19:31 |
guozh...@apache.org |
[1/3] kafka git commit: KAFKA-3715: Add granular metrics to Kafka Streams and add hierarhical logging levels to Metrics |
Wed, 11 Jan, 19:35 |
guozh...@apache.org |
[2/3] kafka git commit: KAFKA-3715: Add granular metrics to Kafka Streams and add hierarhical logging levels to Metrics |
Wed, 11 Jan, 19:35 |
guozh...@apache.org |
[3/3] kafka git commit: KAFKA-3715: Add granular metrics to Kafka Streams and add hierarhical logging levels to Metrics |
Wed, 11 Jan, 19:35 |
guozh...@apache.org |
[1/3] kafka git commit: KAFKA-3715: Add granular metrics to Kafka Streams and add hierarhical logging levels to Metrics [Forced Update!] |
Wed, 11 Jan, 20:06 |
guozh...@apache.org |
[2/3] kafka git commit: KAFKA-3715: Add granular metrics to Kafka Streams and add hierarhical logging levels to Metrics |
Wed, 11 Jan, 20:06 |
guozh...@apache.org |
[3/3] kafka git commit: KAFKA-3715: Add granular metrics to Kafka Streams and add hierarhical logging levels to Metrics |
Wed, 11 Jan, 20:06 |
j...@apache.org |
kafka git commit: KAFKA-4426; Add close with timeout for KafkaConsumer (KIP-102) |
Thu, 12 Jan, 00:13 |
ij...@apache.org |
kafka git commit: KAFKA-4180; Support clients with different authentication credentials in the same JVM |
Thu, 12 Jan, 01:37 |
guozh...@apache.org |
kafka git commit: KAFKA-4114: Allow different offset reset strategies |
Thu, 12 Jan, 04:30 |
guozh...@apache.org |
kafka git commit: KAFKA-3452; Follow-up: Add SessionWindows |
Thu, 12 Jan, 04:33 |
guozh...@apache.org |
kafka git commit: KAFKA-4603: Fixed the argument of shell in doc |
Thu, 12 Jan, 19:25 |
gwens...@apache.org |
kafka git commit: MINOR: Fix error in design docs |
Thu, 12 Jan, 19:28 |
guozh...@apache.org |
[1/5] kafka git commit: KAFKA-4490: Add Global Table support to Kafka Streams |
Thu, 12 Jan, 19:46 |
guozh...@apache.org |
[2/5] kafka git commit: KAFKA-4490: Add Global Table support to Kafka Streams |
Thu, 12 Jan, 19:46 |
guozh...@apache.org |
[3/5] kafka git commit: KAFKA-4490: Add Global Table support to Kafka Streams |
Thu, 12 Jan, 19:46 |
guozh...@apache.org |
[4/5] kafka git commit: KAFKA-4490: Add Global Table support to Kafka Streams |
Thu, 12 Jan, 19:46 |
guozh...@apache.org |
[5/5] kafka git commit: KAFKA-4490: Add Global Table support to Kafka Streams |
Thu, 12 Jan, 19:46 |
guozh...@apache.org |
kafka git commit: MINOR: fix JavaDoc in SegmentIterator |
Thu, 12 Jan, 23:44 |
ewe...@apache.org |
[1/2] kafka git commit: KAFKA-3209: KIP-66: single message transforms |
Fri, 13 Jan, 00:15 |
ewe...@apache.org |
[2/2] kafka git commit: KAFKA-3209: KIP-66: single message transforms |
Fri, 13 Jan, 00:15 |
guozh...@apache.org |
kafka git commit: MINOR: make methods introduced in KAFKA-4490 consistent with KIP-100 |
Fri, 13 Jan, 00:20 |
ewe...@apache.org |
kafka git commit: MINOR: avoid closing over both pre & post-transform record in WorkerSourceTask |
Fri, 13 Jan, 01:09 |
ij...@apache.org |
kafka git commit: MINOR: Remove unnecessary options in SCRAM test jaas config |
Fri, 13 Jan, 02:21 |
ij...@apache.org |
kafka git commit: MINOR: Minor improvements in consumer close timeout handling |
Fri, 13 Jan, 02:31 |
ij...@apache.org |
kafka git commit: KAFKA-4581; Fail early if multiple client login modules in sasl.jaas.config |
Fri, 13 Jan, 10:34 |
j...@apache.org |
kafka git commit: KAFKA-4626; Add KafkaConsumer#close change to upgrade notes |
Fri, 13 Jan, 17:32 |
j...@apache.org |
[1/3] kafka git commit: KAFKA-4565; Separation of Internal and External traffic (KIP-103) |
Fri, 13 Jan, 18:07 |
j...@apache.org |
[2/3] kafka git commit: KAFKA-4565; Separation of Internal and External traffic (KIP-103) |
Fri, 13 Jan, 18:07 |
j...@apache.org |
[3/3] kafka git commit: KAFKA-4565; Separation of Internal and External traffic (KIP-103) |
Fri, 13 Jan, 18:07 |
ewe...@apache.org |
kafka git commit: MINOR: Cluster file generator should produce valid json |
Fri, 13 Jan, 18:22 |
ij...@apache.org |
kafka git commit: MINOR: Remove unneeded client used API lists |
Fri, 13 Jan, 19:06 |
j...@apache.org |
kafka git commit: KAFKA-4627; Fix timing issue in consumer close tests |
Fri, 13 Jan, 19:09 |
guozh...@apache.org |
kafka git commit: HOTFIX: Added another broker to smoke test |
Fri, 13 Jan, 19:11 |
guozh...@apache.org |
kafka git commit: KAFKA-3739: Add no-arg constructor for WindowedSerdes in Streams |
Fri, 13 Jan, 19:13 |
guozh...@apache.org |
kafka git commit: MINOR: Remove unnecessary store info from TopologyBuilder |
Fri, 13 Jan, 19:28 |
ewe...@apache.org |
kafka git commit: KAFKA-4381: Add per partition lag metrics to the consumer |
Fri, 13 Jan, 19:38 |
j...@apache.org |
[1/2] kafka git commit: KAFKA-3853; Extend OffsetFetch API to allow fetching all offsets for a consumer group (KIP-88) |
Sat, 14 Jan, 01:19 |
j...@apache.org |
[2/2] kafka git commit: KAFKA-3853; Extend OffsetFetch API to allow fetching all offsets for a consumer group (KIP-88) |
Sat, 14 Jan, 01:19 |
jun...@apache.org |
kafka git commit: KAFKA-3857; Additional log cleaner metrics |
Sat, 14 Jan, 02:30 |
j...@apache.org |
[1/2] kafka git commit: KAFKA-4591; Create Topic Policy (KIP-108) |
Sat, 14 Jan, 04:01 |
j...@apache.org |
[2/2] kafka git commit: KAFKA-4591; Create Topic Policy (KIP-108) |
Sat, 14 Jan, 04:01 |
ij...@apache.org |
kafka git commit: MINOR: replace remove() with delete() after 5.0.1 RocksDB upgrade |
Sun, 15 Jan, 09:55 |
ij...@apache.org |
kafka git commit: KAFKA-4622; Consumer should handle group authorization errors in offset fetch |
Mon, 16 Jan, 10:56 |
guozh...@apache.org |
kafka git commit: KAFKA-4619: Dissallow to output records with unknown keys in TransformValues |
Mon, 16 Jan, 19:24 |
ewe...@apache.org |
kafka git commit: Bump version to 0.10.3.0-SNAPSHOT |
Mon, 16 Jan, 19:39 |
ewe...@apache.org |
[kafka] Git Push Summary |
Mon, 16 Jan, 19:40 |
guozh...@apache.org |
kafka git commit: MINOR: Remove unused constructor param from ProcessorStateManager |
Mon, 16 Jan, 19:40 |
guozh...@apache.org |
kafka git commit: MINOR: Remove unused constructor param from ProcessorStateManager |
Tue, 17 Jan, 04:01 |