guozh...@apache.org |
kafka git commit: KAFKA-4677 Follow Up: add optimization to StickyTaskAssignor for rolling rebounce |
Wed, 01 Mar, 19:21 |
guozh...@apache.org |
kafka git commit: MINOR: improve MinTimestampTrackerTest and fix NPE when null element removed |
Wed, 01 Mar, 20:07 |
guozh...@apache.org |
kafka git commit: MINOR: Minor reduce unnecessary calls to time.millisecond (part 2) |
Wed, 01 Mar, 22:36 |
jun...@apache.org |
kafka git commit: KAFKA4811; ReplicaFetchThread may fail to create due to existing metric |
Thu, 02 Mar, 17:55 |
guozh...@apache.org |
kafka git commit: KAFKA-2358: Cluster collection returning methods never return null |
Thu, 02 Mar, 21:13 |
guozh...@apache.org |
kafka git commit: KAFKA-4652: Added tests for KStreamBuilder |
Thu, 02 Mar, 21:19 |
guozh...@apache.org |
kafka git commit: MINOR: Fix typo in GlobalKTable javadocs |
Thu, 02 Mar, 21:23 |
|
kafka git commit: KAFKA-4800: Streams State transition ASCII diagrams need fixing and polishing |
|
guozh...@apache.org |
kafka git commit: KAFKA-4800: Streams State transition ASCII diagrams need fixing and polishing |
Thu, 02 Mar, 21:26 |
guozh...@apache.org |
kafka git commit: KAFKA-4800: Streams State transition ASCII diagrams need fixing and polishing |
Thu, 02 Mar, 21:26 |
|
kafka git commit: KAFKA-4631; Request metadata in consumer if topic/partitions unavailable |
|
j...@apache.org |
kafka git commit: KAFKA-4631; Request metadata in consumer if topic/partitions unavailable |
Fri, 03 Mar, 01:54 |
j...@apache.org |
kafka git commit: KAFKA-4631; Request metadata in consumer if topic/partitions unavailable |
Thu, 16 Mar, 22:02 |
j...@apache.org |
kafka git commit: KAFKA-2857; Retry querying the consumer group while initializing |
Fri, 03 Mar, 20:04 |
ij...@apache.org |
kafka git commit: MINOR: Bump version to 0.11.0.0-SNAPSHOT |
Fri, 03 Mar, 22:23 |
|
kafka git commit: MINOR: Fix tests/docker/Dockerfile |
|
ewe...@apache.org |
kafka git commit: MINOR: Fix tests/docker/Dockerfile |
Sat, 04 Mar, 00:40 |
ewe...@apache.org |
kafka git commit: MINOR: Fix tests/docker/Dockerfile |
Sat, 04 Mar, 00:40 |
ij...@apache.org |
kafka git commit: KAFKA-2857; MINOR: Follow up to MINOR: Fix ResetIntegrationTest test failures |
Sat, 04 Mar, 00:50 |
ij...@apache.org |
kafka git commit: KAFKA-4796; Fix some findbugs warnings in Kafka Java client |
Sat, 04 Mar, 00:52 |
ij...@apache.org |
kafka git commit: KAFKA-3182; Fix testSocketsCloseOnShutdown transient failures |
Sat, 04 Mar, 15:28 |
j...@apache.org |
kafka git commit: KAFKA-4820; ConsumerNetworkClient.send() should not require global lock |
Sat, 04 Mar, 19:39 |
guozh...@apache.org |
kafka git commit: MINOR: Standardised benchmark params for consumer and streams |
Sun, 05 Mar, 04:55 |
guozh...@apache.org |
kafka git commit: KAFKA-4826: Fix some findbugs warnings in Kafka Streams |
Sun, 05 Mar, 18:01 |
gwens...@apache.org |
kafka git commit: KAFKA-4276: Add REST configuration in connector properties |
Sun, 05 Mar, 18:21 |
gwens...@apache.org |
kafka git commit: KAFKA-4567 - Connect Producer and Consumer ignore ssl parameters… |
Sun, 05 Mar, 18:28 |
guozh...@apache.org |
kafka git commit: KAFKA-4828: ProcessorTopologyTestDriver does not work when using through |
Mon, 06 Mar, 06:42 |
ij...@apache.org |
kafka git commit: MINOR: additional refactoring around the use of Errors |
Mon, 06 Mar, 10:46 |
ij...@apache.org |
kafka git commit: KAFKA-3989; Initial support for adding a JMH benchmarking module |
Mon, 06 Mar, 11:56 |
ij...@apache.org |
kafka git commit: KAFKA-4266; ReassignPartitionsClusterTest: ensure ZK publication is completed before start |
Mon, 06 Mar, 13:32 |
|
kafka git commit: HOTFIX: fix broken link for wordcount demo example |
|
guozh...@apache.org |
kafka git commit: HOTFIX: fix broken link for wordcount demo example |
Mon, 06 Mar, 17:52 |
guozh...@apache.org |
kafka git commit: HOTFIX: fix broken link for wordcount demo example |
Mon, 06 Mar, 17:53 |
ij...@apache.org |
kafka git commit: KAFKA-3155; Avoid long overflow in RecordBatch#maybeExpire |
Mon, 06 Mar, 21:20 |
|
kafka git commit: KAFKA-4251: fix test driver not launching in Vagrant 1.8.6 |
|
ij...@apache.org |
kafka git commit: KAFKA-4251: fix test driver not launching in Vagrant 1.8.6 |
Tue, 07 Mar, 00:03 |
ij...@apache.org |
kafka git commit: KAFKA-4251: fix test driver not launching in Vagrant 1.8.6 |
Tue, 07 Mar, 00:04 |
ij...@apache.org |
kafka git commit: MINOR: Rename RecordBatch to ProducerBatch to free the name for KIP-98 |
Tue, 07 Mar, 01:31 |
|
kafka git commit: KAFKA-4851: only search available segments during Segments.segments(from, to) |
|
guozh...@apache.org |
kafka git commit: KAFKA-4851: only search available segments during Segments.segments(from, to) |
Tue, 07 Mar, 23:31 |
guozh...@apache.org |
kafka git commit: KAFKA-4851: only search available segments during Segments.segments(from, to) |
Tue, 07 Mar, 23:33 |
ij...@apache.org |
kafka git commit: KAFKA-4841; NetworkClient should only consider a connection to have failed after attempt to connect |
Wed, 08 Mar, 01:11 |
guozh...@apache.org |
kafka git commit: KAFKA-4722: Add application.id to StreamThread name |
Wed, 08 Mar, 19:40 |
ij...@apache.org |
kafka git commit: MINOR: Add varint serde utilities for new message format |
Wed, 08 Mar, 22:26 |
ij...@apache.org |
kafka git commit: MINOR: Use ConcurrentMap for ConsumerNetworkClient UnsentRequests |
Wed, 08 Mar, 23:17 |
ij...@apache.org |
kafka git commit: KAFKA-4745; Remove unnecessary flush in KafkaLZ4BlockOutputStream.close() |
Thu, 09 Mar, 01:02 |
|
kafka git commit: KAFKA-4864; added correct zookeeper nodes for security migrator |
|
jun...@apache.org |
kafka git commit: KAFKA-4864; added correct zookeeper nodes for security migrator |
Thu, 09 Mar, 05:41 |
jun...@apache.org |
kafka git commit: KAFKA-4864; added correct zookeeper nodes for security migrator |
Thu, 09 Mar, 05:42 |
j...@apache.org |
kafka git commit: MINOR: Introduce NetworkClient.hasInFlightRequests |
Thu, 09 Mar, 17:46 |
ewe...@apache.org |
kafka git commit: KAFKA-4467: Run tests on travis-ci using docker |
Fri, 10 Mar, 00:24 |
|
kafka git commit: KAFKA-4861; GroupMetadataManager record is rejected if broker configured with LogAppendTime |
|
j...@apache.org |
kafka git commit: KAFKA-4861; GroupMetadataManager record is rejected if broker configured with LogAppendTime |
Fri, 10 Mar, 01:40 |
j...@apache.org |
kafka git commit: KAFKA-4861; GroupMetadataManager record is rejected if broker configured with LogAppendTime |
Fri, 10 Mar, 02:24 |
guozh...@apache.org |
kafka git commit: MINOR: KStream: fix typo in javadoc |
Fri, 10 Mar, 15:51 |
guozh...@apache.org |
kafka git commit: KAFKA-4738: Remove generic type of class ClientState |
Fri, 10 Mar, 19:28 |