| ewe...@apache.org |
kafka git commit: MINOR: Move streams-examples source files under src folder |
Wed, 02 Mar, 02:54 |
| ewe...@apache.org |
kafka git commit: KAFKA-3257: disable bootstrap-test-env.sh --colour option |
Wed, 02 Mar, 07:53 |
| ewe...@apache.org |
kafka git commit: KAFKA-2944: Replaced the NPE with a nicer error and clean exit and added debug message to assist with figuring this out. |
Thu, 03 Mar, 02:51 |
| ewe...@apache.org |
kafka git commit: KAFKA-3324; NullPointerException in StreamPartitionAssignor |
Thu, 03 Mar, 10:53 |
| ewe...@apache.org |
kafka git commit: KAFKA-2934; Offset storage file configuration in Connect standalone mode is not included in StandaloneConfig |
Thu, 03 Mar, 16:55 |
| ewe...@apache.org |
kafka git commit: KAFKA-3299: Ensure that reading config log on rebalance doesn't hang the herder |
Fri, 04 Mar, 22:21 |
| ewe...@apache.org |
kafka git commit: KAFKA-3201: Added rolling upgrade system tests from 0.8 and 0.9 to 0.10 |
Tue, 08 Mar, 07:18 |
| ewe...@apache.org |
kafka git commit: KAFKA-3237: Allow ConfigDef options with no default and validator |
Wed, 09 Mar, 05:56 |
| ewe...@apache.org |
kafka git commit: MINOR: Clean up of ProducerConfig documentation, including correction for block.on.buffer.full |
Wed, 09 Mar, 06:53 |
| ewe...@apache.org |
kafka git commit: KAFKA-3279: Remove checks for JAAS system property |
Wed, 09 Mar, 07:40 |
| ewe...@apache.org |
kafka git commit: MINOR: Update gradlew.bat as per latest gradle release |
Wed, 09 Mar, 17:24 |
| ewe...@apache.org |
kafka git commit: KAFKA-3344: Remove previous system test's leftover test-log4j.properties |
Thu, 10 Mar, 07:55 |
| ewe...@apache.org |
kafka git commit: MINOR: Fix system test broken by change of consumer group tool output format |
Thu, 10 Mar, 19:12 |
| ewe...@apache.org |
kafka git commit: MINOR: Add unit test for internal topics |
Thu, 10 Mar, 22:54 |
| ewe...@apache.org |
kafka git commit: MINOR: Remove unused import in `WordCountJob` to fix checkstyle failure |
Tue, 15 Mar, 20:37 |
| ewe...@apache.org |
kafka git commit: KAFKA-3260 - Added SourceTask.commitRecord |
Tue, 15 Mar, 21:32 |
| ewe...@apache.org |
kafka git commit: MINOR: KAFKA-3260 follow up, fix commitRecord calls in tests |
Wed, 16 Mar, 15:26 |
| ewe...@apache.org |
kafka git commit: KAFKA-3371: ClientCompatibilityTest system test failing |
Wed, 16 Mar, 15:47 |
| ewe...@apache.org |
[1/2] kafka git commit: KAFKA-3315: Add REST and Connector API to expose connector configuration |
Thu, 17 Mar, 20:26 |
| ewe...@apache.org |
[2/2] kafka git commit: KAFKA-3315: Add REST and Connector API to expose connector configuration |
Thu, 17 Mar, 20:26 |
| ewe...@apache.org |
kafka git commit: HOTFIX: Renamed tests to match expected suffix |
Fri, 18 Mar, 19:02 |
| ewe...@apache.org |
kafka git commit: MINOR: Add vagrant up wrapper for simple parallel bringup on aws |
Sun, 20 Mar, 23:46 |
| ewe...@apache.org |
kafka git commit: MINOR: fix documentation version |
Mon, 21 Mar, 20:16 |
| ewe...@apache.org |
kafka git commit: MINOR: fix documentation version |
Mon, 21 Mar, 20:16 |
| ewe...@apache.org |
kafka git commit: MINOR: update new version in additional places |
Mon, 21 Mar, 20:41 |
| ewe...@apache.org |
kafka git commit: MINOR: update new version in additional places |
Tue, 22 Mar, 01:59 |
| ewe...@apache.org |
kafka git commit: KAFKA-3412: multiple asynchronous commits causes send failures |
Tue, 22 Mar, 03:47 |
| ewe...@apache.org |
kafka git commit: KAFKA-3412: multiple asynchronous commits causes send failures |
Tue, 22 Mar, 03:48 |
| ewe...@apache.org |
kafka git commit: KAFKA-3434; add old constructor to ConsumerRecord |
Thu, 24 Mar, 05:36 |
| ewe...@apache.org |
kafka git commit: KAFKA-3434; add old constructor to ConsumerRecord |
Thu, 24 Mar, 05:37 |
| ewe...@apache.org |
kafka git commit: KAFKA-3445: Validate TASKS_MAX_CONFIG's lower bound |
Thu, 24 Mar, 17:12 |
| ewe...@apache.org |
kafka git commit: KAFKA-3407 - ErrorLoggingCallback trims helpful diagnostic information. |
Thu, 24 Mar, 18:03 |
| ewe...@apache.org |
kafka git commit: KAFKA-3316: Add REST API for listing connector plugins |
Fri, 25 Mar, 23:47 |
| ewe...@apache.org |
kafka git commit: KAFKA-3316: Add REST API for listing connector plugins |
Fri, 25 Mar, 23:47 |
| ewe...@apache.org |
kafka git commit: MINOR: Advance system test ducktape dependency from 0.3.10 to 0.4.0 |
Wed, 30 Mar, 07:50 |
| ewe...@apache.org |
kafka git commit: MINOR: Advance system test ducktape dependency from 0.3.10 to 0.4.0 |
Wed, 30 Mar, 07:51 |
| guozh...@apache.org |
kafka git commit: MINOR: Add AUTO_OFFSET_RESET_CONFIG to StreamsConfig; remove TOTAL_RECORDS_TO_PROCESS from StreamsConfig |
Tue, 01 Mar, 00:05 |
| guozh...@apache.org |
kafka git commit: MINOR: DefaultMessageFormatter custom deserializer fixes |
Tue, 01 Mar, 00:10 |
| guozh...@apache.org |
kafka git commit: HOTFIX: Use the correct serde classes |
Wed, 02 Mar, 00:27 |
| guozh...@apache.org |
kafka git commit: KAFKA-3311; Prepare internal source topics before calling partition grouper |
Wed, 02 Mar, 21:43 |
| guozh...@apache.org |
kafka git commit: MINOR: Improve JavaDoc for some public classes. |
Thu, 03 Mar, 00:11 |
| guozh...@apache.org |
kafka git commit: HOTFIX: Fix checkstyle failure in KStreams by providing fully qualified class names. |
Thu, 03 Mar, 07:42 |
| guozh...@apache.org |
kafka git commit: HOTFIX: Avoid NPE in StreamsPartitionAssignor |
Thu, 03 Mar, 16:57 |
| guozh...@apache.org |
kafka git commit: KAFKA-3233: expose consumer per-topic metrics |
Sat, 05 Mar, 23:17 |
| guozh...@apache.org |
kafka git commit: MINOR: Ignoring streams tests until there is fix for KAFKA-3354 |
Wed, 09 Mar, 05:40 |
| guozh...@apache.org |
kafka git commit: MINOR: update compression design doc to include lz4 protocol |
Fri, 11 Mar, 18:56 |
| guozh...@apache.org |
kafka git commit: KAFKA-3047: Explicit offset assignment in Log.append can corrupt the log |
Sat, 12 Mar, 01:53 |
| guozh...@apache.org |
kafka git commit: KAFKA-3395: prefix job id to internal topic names |
Mon, 14 Mar, 21:50 |
| guozh...@apache.org |
kafka git commit: MINOR: Remove unused method, redundant in interface definition and add final for object used in sychronization |
Mon, 14 Mar, 22:09 |
| guozh...@apache.org |
kafka git commit: MINOR: kstream/ktable counting method with default long serdes |
Tue, 15 Mar, 19:08 |
| guozh...@apache.org |
kafka git commit: MINOR: Add test that verifies fix for KAFKA-3047 |
Tue, 15 Mar, 19:15 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-3411: Streams: stop using "job" terminology, rename job.id to application.id |
Thu, 17 Mar, 17:41 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-3411: Streams: stop using "job" terminology, rename job.id to application.id |
Thu, 17 Mar, 17:41 |
| guozh...@apache.org |
kafka git commit: KAFKA-3392: ConsumerRecords iterator throws NoSuchElementException when a TopicPartition is empty |
Thu, 17 Mar, 17:52 |
| guozh...@apache.org |
[1/4] kafka git commit: KAFKA-3336: Unify Serializer and Deserializer into Serialization |
Thu, 17 Mar, 22:42 |
| guozh...@apache.org |
[2/4] kafka git commit: KAFKA-3336: Unify Serializer and Deserializer into Serialization |
Thu, 17 Mar, 22:42 |
| guozh...@apache.org |
[3/4] kafka git commit: KAFKA-3336: Unify Serializer and Deserializer into Serialization |
Thu, 17 Mar, 22:42 |
| guozh...@apache.org |
[4/4] kafka git commit: KAFKA-3336: Unify Serializer and Deserializer into Serialization |
Thu, 17 Mar, 22:42 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-3422: Add overloading functions without serdes in Streams DSL |
Fri, 18 Mar, 19:39 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-3422: Add overloading functions without serdes in Streams DSL |
Fri, 18 Mar, 19:39 |
| guozh...@apache.org |
kafka git commit: KAFKA-3397: use -1(latest) as time default value for tools.GetOffsetShell |
Fri, 18 Mar, 20:43 |
| guozh...@apache.org |
kafka git commit: MINOR: Add InterfaceStability.Unstable annotations to some Kafka Streams public APIs |
Mon, 21 Mar, 19:06 |
| guozh...@apache.org |
kafka git commit: MINOR: Add InterfaceStability.Unstable annotations to some Kafka Streams public APIs |
Mon, 21 Mar, 19:06 |
| guozh...@apache.org |
kafka git commit: KAFKA-3319: improve session timeout broker/client config documentation |
Tue, 22 Mar, 20:09 |
| guozh...@apache.org |
kafka git commit: KAFKA-3319: improve session timeout broker/client config documentation |
Tue, 22 Mar, 20:09 |
| guozh...@apache.org |
kafka git commit: KAFKA-3409: handle CommitFailedException in MirrorMaker |
Wed, 23 Mar, 16:47 |
| guozh...@apache.org |
kafka git commit: KAFKA-3409: handle CommitFailedException in MirrorMaker |
Wed, 23 Mar, 16:48 |
| guozh...@apache.org |
kafka git commit: KAFKA-3432; Cluster.update() thread-safety |
Wed, 23 Mar, 20:53 |
| guozh...@apache.org |
kafka git commit: KAFKA-3432; Cluster.update() thread-safety |
Wed, 23 Mar, 20:53 |
| guozh...@apache.org |
kafka git commit: HOTFIX: fix NPE in changelogger |
Wed, 23 Mar, 21:25 |
| guozh...@apache.org |
kafka git commit: HOTFIX: fix NPE in changelogger |
Wed, 23 Mar, 21:25 |
| guozh...@apache.org |
kafka git commit: MINOR: remove streams-smoke-test.sh |
Wed, 23 Mar, 21:57 |
| guozh...@apache.org |
kafka git commit: MINOR: remove streams-smoke-test.sh |
Wed, 23 Mar, 21:57 |
| guozh...@apache.org |
kafka git commit: KAFKA-3449: Rename filterOut() to filterNot() to achieve better terminology |
Fri, 25 Mar, 22:00 |
| guozh...@apache.org |
kafka git commit: KAFKA-3449: Rename filterOut() to filterNot() to achieve better terminology |
Fri, 25 Mar, 22:01 |
| guozh...@apache.org |
kafka git commit: MINOR: Remove a couple of redundant `CoreUtils.rm` methods |
Mon, 28 Mar, 21:35 |
| guozh...@apache.org |
kafka git commit: MINOR: Remove a couple of redundant `CoreUtils.rm` methods |
Mon, 28 Mar, 21:35 |
| guozh...@apache.org |
kafka git commit: HOTFIX: RocksDBStore must clear dirty flags after flush |
Tue, 29 Mar, 20:30 |
| guozh...@apache.org |
kafka git commit: HOTFIX: RocksDBStore must clear dirty flags after flush |
Tue, 29 Mar, 20:31 |
| guozh...@apache.org |
kafka git commit: KAFKA-3425: add missing upgrade notes |
Tue, 29 Mar, 21:19 |
| guozh...@apache.org |
kafka git commit: KAFKA-3425: add missing upgrade notes |
Tue, 29 Mar, 21:19 |
| guozh...@apache.org |
kafka git commit: MINOR: a simple benchmark for Streams |
Wed, 30 Mar, 21:26 |
| guozh...@apache.org |
kafka git commit: MINOR: a simple benchmark for Streams |
Wed, 30 Mar, 21:26 |
| gwens...@apache.org |
kafka git commit: KAFKA-3290: fix transient test failures in WorkerSourceTaskTest |
Thu, 03 Mar, 01:22 |
| gwens...@apache.org |
kafka git commit: MINOR: fix typo |
Thu, 03 Mar, 01:23 |
| gwens...@apache.org |
kafka git commit: KAFKA-2784: swallow exceptions when mirror maker exits. |
Thu, 03 Mar, 02:22 |
| gwens...@apache.org |
kafka git commit: KAFKA-3314: Add CDDL license to LICENSE and NOTICE file |
Thu, 03 Mar, 19:43 |
| gwens...@apache.org |
kafka git commit: MINOR: Fix typos in docs |
Thu, 03 Mar, 19:46 |
| gwens...@apache.org |
kafka git commit: KAFKA-3325: Out of date instructions in quickstart guide |
Thu, 03 Mar, 19:47 |
| gwens...@apache.org |
kafka git commit: KAFKA-3290: fix race condition with worker task shutdown and mock validation |
Thu, 03 Mar, 22:58 |
| gwens...@apache.org |
kafka git commit: KAFKA-3286: Add plugin to quickly check for outdated dependencies |
Thu, 03 Mar, 23:10 |
| gwens...@apache.org |
kafka git commit: KAFKA-3187: Make kafka-acls.sh help messages more generic. |
Fri, 04 Mar, 01:34 |
| gwens...@apache.org |
kafka git commit: KAFKA-3281: Improve message of *-server-stop.sh when process is not running |
Fri, 04 Mar, 01:41 |
| gwens...@apache.org |
kafka git commit: HOTFIX: Generate javadocs for all Streams packages with the exception of internals |
Fri, 04 Mar, 18:28 |
| gwens...@apache.org |
kafka git commit: KAFKA-3339: Fix java docs for seekToEnd and seekToBeginning. |
Mon, 07 Mar, 19:28 |
| gwens...@apache.org |
kafka git commit: MINOR: streams javadoc corrections |
Mon, 07 Mar, 19:32 |
| gwens...@apache.org |
kafka git commit: KAFKA-3341: Improve error handling on invalid requests |
Mon, 07 Mar, 19:34 |
| gwens...@apache.org |
kafka git commit: MINOR: Remove usage of deprecated junit.framework.Assert |
Tue, 08 Mar, 02:24 |
| gwens...@apache.org |
kafka git commit: MINOR: tidy up spacing for ConsumerGroupCommand related to KAFKA-1476 … |
Tue, 08 Mar, 02:30 |
| gwens...@apache.org |
kafka git commit: KAFKA-2068; KAFKA-2069; Replace OffsetCommit and OffsetFetch Request/… |
Tue, 08 Mar, 02:33 |