| 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 |
| ewe...@apache.org |
kafka git commit: KAFKA-4467: Run tests on travis-ci using docker |
Fri, 10 Mar, 00:24 |
| ewe...@apache.org |
kafka git commit: KAFKA-4783: Add ByteArrayConverter (KIP-128) |
Wed, 15 Mar, 00:20 |
| ewe...@apache.org |
kafka git commit: KAFKA-4924: Fix Kafka Connect API findbugs warnings |
Tue, 21 Mar, 23:48 |
| ewe...@apache.org |
kafka git commit: MINOR: Pluggable verifiable clients |
Wed, 22 Mar, 05:23 |
| ewe...@apache.org |
kafka git commit: MINOR: Adding example to SMT documentation |
Thu, 23 Mar, 06:05 |
| ewe...@apache.org |
kafka git commit: MINOR: Adding example to SMT documentation |
Thu, 23 Mar, 06:05 |
| ewe...@apache.org |
kafka git commit: HOTFIX: Fix unsafe dependence on class name in VerifiableClientJava |
Sat, 25 Mar, 02:41 |
| ewe...@apache.org |
kafka git commit: KAFKA-4575: ensure topic created before starting sink for ConnectDistributedTest.test_pause_resume_sink |
Tue, 28 Mar, 00:46 |
| ewe...@apache.org |
kafka git commit: KAFKA-4575: ensure topic created before starting sink for ConnectDistributedTest.test_pause_resume_sink |
Tue, 28 Mar, 00:47 |
| 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 |
| 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 |
| 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 |
| 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 |
| guozh...@apache.org |
kafka git commit: KAFKA-4828: ProcessorTopologyTestDriver does not work when using through |
Mon, 06 Mar, 06:42 |
| 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 |
| 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 |
| guozh...@apache.org |
kafka git commit: KAFKA-4722: Add application.id to StreamThread name |
Wed, 08 Mar, 19:40 |
| 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 |
| guozh...@apache.org |
kafka git commit: MINOR: increase RocksDb parallelism |
Fri, 10 Mar, 21:43 |
| guozh...@apache.org |
kafka git commit: MINOR: increase RocksDb parallelism |
Fri, 10 Mar, 21:45 |
| guozh...@apache.org |
kafka git commit: MINOR: incorrect javadoc formatting |
Sat, 11 Mar, 00:48 |
| guozh...@apache.org |
kafka git commit: MINOR: incorrect javadoc formatting |
Sat, 11 Mar, 00:49 |
| guozh...@apache.org |
kafka git commit: KAFKA-4769: Add Float serializer, deserializer, serde |
Mon, 13 Mar, 18:49 |
| guozh...@apache.org |
kafka git commit: KAFKA-4657: Improve test coverage of CompositeReadOnlyWindowStore |
Mon, 13 Mar, 19:05 |
| guozh...@apache.org |
kafka git commit: KAFKA-4863; Querying window store may return unwanted keys |
Tue, 14 Mar, 21:21 |
| guozh...@apache.org |
kafka git commit: KAFKA-4885: Add client.close as exception handler in streams system tests |
Fri, 17 Mar, 05:33 |
| guozh...@apache.org |
kafka git commit: KAFKA-4859: Set shorter commit interval for integration tests with caching |
Fri, 17 Mar, 05:36 |
| guozh...@apache.org |
kafka git commit: KAFKA-4607: Validate the names of auto-generated internal topics |
Fri, 17 Mar, 19:03 |
| guozh...@apache.org |
kafka git commit: MINOR: Guard against NPE when throwing StreamsException on serializer mismatch |
Fri, 17 Mar, 22:18 |
| guozh...@apache.org |
kafka git commit: KAFKA-4848: Fix retryWithBackoff deadlock issue |
Tue, 21 Mar, 04:56 |
| guozh...@apache.org |
kafka git commit: KAFKA-4863 Follow-up: Querying window store may return unwanted keys |
Tue, 21 Mar, 23:12 |
| guozh...@apache.org |
kafka git commit: KAFKA-4863: Querying window store may return unwanted keys. Backport to 0.10.2 |
Tue, 21 Mar, 23:14 |
| guozh...@apache.org |
kafka git commit: MINOR: remove unused log field from KStreamTransformValuesProcessor |
Tue, 21 Mar, 23:17 |
| guozh...@apache.org |
kafka git commit: MINOR: remove unused log field from KStreamTransformValuesProcessor |
Tue, 21 Mar, 23:17 |
| guozh...@apache.org |
kafka git commit: MINOR: updated incorrect JavaDocs for joins |
Tue, 21 Mar, 23:21 |
| guozh...@apache.org |
kafka git commit: MINOR: updated incorrect JavaDocs for joins |
Wed, 22 Mar, 01:36 |
| guozh...@apache.org |
kafka git commit: MINOR: log start and end offsets for state store restoration |
Wed, 22 Mar, 02:14 |
| guozh...@apache.org |
kafka git commit: MINOR: improve hanging ResetIntegrationTest |
Wed, 22 Mar, 02:18 |
| guozh...@apache.org |
kafka git commit: MINOR: improve hanging ResetIntegrationTest |
Wed, 22 Mar, 02:20 |
| guozh...@apache.org |
kafka git commit: MINOR: MyProcessor doc example should implement, not extend `Processor` |
Wed, 22 Mar, 19:23 |
| guozh...@apache.org |
kafka git commit: MINOR: MyProcessor doc example should implement, not extend `Processor` |
Wed, 22 Mar, 19:23 |
| guozh...@apache.org |
kafka git commit: MINOR: log state store restore offsets |
Wed, 22 Mar, 19:24 |
| guozh...@apache.org |
kafka git commit: MINOR: Improvements on Streams log4j |
Wed, 22 Mar, 21:33 |
| guozh...@apache.org |
kafka git commit: KAFKA-4919: Document that stores must not be closed when Processors are closed |
Thu, 23 Mar, 16:47 |
| guozh...@apache.org |
kafka git commit: KAFKA-4919: Document that stores must not be closed when Processors are closed |
Thu, 23 Mar, 16:48 |
| guozh...@apache.org |
kafka git commit: MINOR: only log first exception in RecordCollectorImpl producer callback |
Thu, 23 Mar, 17:05 |
| guozh...@apache.org |
kafka git commit: MINOR: only log first exception in RecordCollectorImpl producer callback |
Thu, 23 Mar, 17:05 |
| guozh...@apache.org |
kafka git commit: KAFKA-4881: add internal leave.group.on.close config to consumer |
Mon, 27 Mar, 17:30 |
| guozh...@apache.org |
kafka git commit: KAFKA-4843: More efficient round-robin scheduler |
Wed, 29 Mar, 22:00 |
| guozh...@apache.org |
kafka git commit: KAFKA-4980: testReprocessingFromScratch unit test failure |
Thu, 30 Mar, 20:30 |
| guozh...@apache.org |
kafka git commit: MINOR: reduce amount of verbose printing |
Thu, 30 Mar, 20:47 |
| guozh...@apache.org |
kafka git commit: KAFKA-4791: unable to add state store with regex matched topics |
Thu, 30 Mar, 22:44 |
| guozh...@apache.org |
kafka git commit: KAFKA-4791: unable to add state store with regex matched topics |
Thu, 30 Mar, 22:48 |
| guozh...@apache.org |
kafka git commit: MINOR: Increase max.poll time for streams consumers |
Thu, 30 Mar, 22:58 |
| guozh...@apache.org |
kafka git commit: MINOR: Increase max.poll time for streams consumers |
Thu, 30 Mar, 23:00 |
| 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 |
| gwens...@apache.org |
kafka git commit: KAFKA-4929: Transformation Key/Value type references should be to class name(), not canonicalName() |
Wed, 22 Mar, 21:02 |
| ij...@apache.org |
kafka git commit: MINOR: Bump version to 0.11.0.0-SNAPSHOT |
Fri, 03 Mar, 22:23 |
| 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 |
| 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 |
| ij...@apache.org |
kafka git commit: KAFKA-3155; Avoid long overflow in RecordBatch#maybeExpire |
Mon, 06 Mar, 21:20 |
| 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 |
| 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 |
| 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 |
| ij...@apache.org |
kafka git commit: HOTFIX: Fix header in ByteArrayConverter |
Wed, 15 Mar, 14:47 |
| ij...@apache.org |
kafka git commit: MINOR: Log error if offsets topic creation fails |
Fri, 17 Mar, 10:26 |
| ij...@apache.org |
kafka git commit: MINOR: Increase Throttle lower bound assertion in throttling_test |
Fri, 17 Mar, 12:40 |
| ij...@apache.org |
kafka git commit: MINOR: Increase Throttle lower bound assertion in throttling_test |
Fri, 17 Mar, 12:40 |
| ij...@apache.org |
kafka git commit: MINOR: Fix non-null check in the constructor of ListenerName |
Fri, 17 Mar, 13:49 |
| ij...@apache.org |
kafka git commit: KAFKA-4895; Fix findbugs "format string should use %n rather than \n" in tools |
Fri, 17 Mar, 13:59 |
| ij...@apache.org |
kafka git commit: MINOR: Fix zookeeper-security-migration documentation example |
Tue, 21 Mar, 09:52 |
| ij...@apache.org |
kafka git commit: MINOR: Fix zookeeper-security-migration documentation example |
Tue, 21 Mar, 09:52 |
| ij...@apache.org |
kafka git commit: KAFKA-4594; Annotate integration tests and provide gradle build targets to run subsets of tests |
Tue, 21 Mar, 10:13 |
| ij...@apache.org |
[01/11] kafka git commit: KAFKA-4816; Message format changes for idempotent/transactional producer (KIP-98) |
Fri, 24 Mar, 19:43 |
| ij...@apache.org |
[02/11] kafka git commit: KAFKA-4816; Message format changes for idempotent/transactional producer (KIP-98) |
Fri, 24 Mar, 19:43 |
| ij...@apache.org |
[03/11] kafka git commit: KAFKA-4816; Message format changes for idempotent/transactional producer (KIP-98) |
Fri, 24 Mar, 19:43 |
| ij...@apache.org |
[04/11] kafka git commit: KAFKA-4816; Message format changes for idempotent/transactional producer (KIP-98) |
Fri, 24 Mar, 19:43 |
| ij...@apache.org |
[05/11] kafka git commit: KAFKA-4816; Message format changes for idempotent/transactional producer (KIP-98) |
Fri, 24 Mar, 19:43 |
| ij...@apache.org |
[06/11] kafka git commit: KAFKA-4816; Message format changes for idempotent/transactional producer (KIP-98) |
Fri, 24 Mar, 19:43 |
| ij...@apache.org |
[07/11] kafka git commit: KAFKA-4816; Message format changes for idempotent/transactional producer (KIP-98) |
Fri, 24 Mar, 19:44 |