SAMZA-1898: New UI layout for the Samza website
[samza.git] / samza-kafka /
2018-08-27  Gaurav AgarwalSAMZA-1822: Samza 0.14.1 not correctly handling OffsetO...
2018-08-27  Prateek MaheshwariSAMZA-1804: System and Stream Descriptors
2018-07-27  Prateek MaheshwariSAMZA-1745: Remove all usages of StreamSpec and Applica...
2018-06-28  Cameron LeeSAMZA-1738: Merge in some minor additions from Linkedin...
2018-06-25  Boris SSAMZA-1753: Added timestamp to Incoming message envelope.
2018-06-06  Prateek MaheshwariMinor: KafkaConfig should treat empty changelog name...
2018-05-25  Yi Pan (Data Infra... SAMZA-1659: Serializable OperatorSpec
2018-05-17  Yi Pan (Data Infra... SAMZA-1715: Unit test for Kafka admin deletedMessagesCa...
2018-04-18  Dong LinSAMZA-1478: Delete unneeded data from intermediate...
2018-04-18  Prateek MaheshwariMisc. Util cleanup
2018-03-09  Shanthoosh Venkata... SAMZA-1589: Reduce failure retry duration in KafkaCheck...
2018-03-06  Yi Pan (Data Infra... SAMZA-1600: remove the combination of cleanup policy...
2018-03-04  Prateek MaheshwariMisc. minor cleanup.
2018-02-21  Srinivasulu PunuruFixes to get the build working with Scala 2.10 build
2018-02-16  Daniel NishimuraSAMZA-1555: Move creation of checkpoint and changelog...
2018-02-13  Shanthoosh Venkata... SAMZA-1572: Add fixed retries on failure in KafkaCheckp...
2018-01-26  Dong LinSAMZA-1548; Add start() and stop() to SystemAdmin
2018-01-24  Xinyu LiuSAMZA-1557: Broadcast operator
2018-01-18  JagadishSAMZA-1560: Handle key-serde errors in KafkaCheckpointM...
2018-01-10  Dong LinSAMZA-1530; Bump up Kafka dependency to 0.11
2017-12-22  JagadishSAMZA-1547; Parse default value grouper-factory config...
2017-12-22  Jacob MaesSAMZA-1539: KafkaProducer potential hang on close(...
2017-11-17  JagadishSAMZA-1479; Refactor KafkaCheckpointManager, KafkaCheck...
2017-11-07  Xinyu LiuSAMZA-1477: Fix issues found by BEAM tests
2017-10-25  Xinyu LiuSAMZA-1457: Set retention for internal streams for...
2017-10-18  Jacob MaesSAMZA-1465: Performance regression for KafkaCheckpointM...
2017-10-13  Boris SChangeLog should not require KafkaSystemAdmin
2017-10-05  Boris SSAMZA-1442: use systemAdmin.validateStream in KafkaChec...
2017-10-04  Jacob MaesSAMZA-1439: Address late review feedback from SAMZA...
2017-10-04  Boris SSAMZA-1427; use systemFactory in checkpoint manager.
2017-10-03  Xinyu LiuMerge branch '0.14.0'
2017-10-03  Xinyu LiuMerge branch 'master' into 0.14.0
2017-09-25  Xinyu LiuSAMZA-1417: Clear and recreate intermediate and metadat...
2017-09-20  Jacob MaesSAMZA-1392: KafkaSystemProducer performance and correct...
2017-09-12  Xinyu LiuMerge branch 'master' into 0.14.0
2017-09-07  Xinyu LiuSAMZA-1415: Add clearStream API in SystemAdmin and...
2017-08-11  Jacob MaesSAMZA-1387: Unable to Start Samza App Because Regex...
2017-08-09  Yi Pan (Data Infra... Merge branch 'master' into 0.14.0
2017-07-17  Boris ShkolnikSAMZA-1336. Session disconnect propagation.
2017-06-03  Jacob MaesSAMZA-1317: Changelog validation error for topics with...
2017-06-02  Jacob MaesSAMZA-1317: Changelog topic configuration should accept...
2017-06-01  Jacob MaesSAMZA-1234: Documentation for 0.13.0 release
2017-05-10  Xinyu LiuSAMZA-1283: Expose the buffered-message-size metric
2017-05-09  Jacob MaesSAMZA-1275: Kafka throws when users configure replicati...
2017-05-03  Navina RameshSAMZA-1212 - Refactor interaction between StreamProcess...
2017-04-27  Jacob MaesSamza 1214: Allow users to set a default replication...
2017-04-14  James LentSAMZA-1145: Provide Ability To Confgure The Default...
2017-03-31  vjagadish1989 SAMZA-1135 - Support scala 2.12
2017-03-11  Tommy BeckerSAMZA-1112; BrokerProxy does not log fatal errors
2017-03-06  Jacob MaesSAMZA-1096: StreamSpec constructors in the ExecutionEnv...
2017-02-17  Jacob MaesSAMZA-1075: Refactor SystemAdmin Interface to expose...
2017-02-09  Shanthoosh Venkata... SAMZA-1083 Do not load task stores which are older...
2017-01-06  Boris ShkolnikSAMZA-1076; getKafkaChangelogEnabledStores() should...
2016-12-23  Xinyu LiuSAMZA-1069: Fix Deadlock between KafkaSystemProducer...
2016-12-23  Shanthoosh Venkata... SAMZA-855; Upgrade Samza's Kafka client version to...
2016-09-29  Xinyu LiuSAMZA-1028: Fix KafkaSystemProducer logging and use...
2016-09-29  vjagadish1989SAMZA-1020: Remove methods in Kafka checkpoint classes...
2016-09-23  Tommy BeckerFix SAMZA-1018.
2016-09-14  Branislav CogicSAMZA-702 - Document the significance of all the differ...
2016-08-18  Xinyu LiuSAMZA-1003: Restore lazy init for kafka system producer
2016-07-29  Xinyu LiuSAMZA-981 - Set consistent Kafka clientId for a job...
2016-07-29  Xinyu LiuSAMZA-979 - Remove KafkaCheckpointMigration
2016-07-19  Xinyu LiuSAMZA-863: Multithreading support in Samza
2016-06-14  Jacob MaesSAMZA-964 - Improve the performance of the continuous...
2016-06-08  Boris ShkolnikSAMZA-962 - Add Java friendly api to KafkaSystemConsume...
2016-05-19  Jacob MaesSAMZA-950: Add backward-compatible KafkaSystemProducer...
2016-04-27  Jagadish VenkatramanSAMZA-911: set a max retry on KafkaSystemProducer to...
2016-04-09  Ivan SimonekoSAMZA-920: BrokerProxy.abdicateAll can get stuck on...
2016-03-25  Navina RameshSAMZA-882 : Detect partition count changes in input...
2016-02-19  Boris ShkolnikSAMZA-864: allow job to continue when checkpoint partit...
2015-11-24  Monal DaxiniSAMZA-775: add consumer size-based fetch threshold
2015-11-19  Yi PanSAMZA-754: set the oldest offset to 0 on empty topic...
2015-11-18  Yan FangSAMZA-753 - BrokerProxy stop should stop the Kafka...
2015-11-02  NavinaSAMZA-798 : Performance and stability issue after combi...
2015-10-19  Aleksandar BircakovicSAMZA-791 - KafkaSystemFactory narrows return types
2015-09-28  Yi PanSAMZA-778: Fix KafkaCheckpointMigration code to avoid...
2015-09-24  Yi Pan (Data Infra... SAMZA-615: Auto-migrate Kafka checkpoints into coordina...
2015-08-24  Yan FangSAMZA-676: Implemented broadcast stream
2015-08-24  Aleksandar PejakovicSAMZA-736: Fixed infinite loop in BrokerProxy when...
2015-08-18  Aleksandar Pejakovic SAMZA-738: Samza timer based metrics does not have...
2015-08-11  Robert ZuljevicSAMZA-690: Move changelog topic creation to JobCoordinator
2015-06-16  rzuljevicSAMZA-546 Add config option max.in.flight.requests...
2015-05-15  Gustavo AnatolySAMZA-643: Improve error messages fro null stream in...
2015-04-29  Naveen SomasundaramSAMZA-465: Use coordinator stream and eliminate Checkpo...
2015-04-02  Dan HarveySAMZA-633; expose configuration to Kafka's encoder...
2015-03-23  Yan FangSAMZA-458; closing kafka system producers flushes all...
2015-03-19  Chris RiccominiSAMZA-586; disable compressed messages when sending...
2015-03-14  Benjamin FradetSAMZA-600: Move Java tests into src/test/java in samza...
2015-03-13  Chris RiccominiSAMZA-592; ignore replica not available exceptions...
2015-03-11  Chris RiccominiSAMZA-590; kafka broker proxy should relinquish ownersh...
2015-03-03  Chris RiccominiSAMZA-584; fix race condition in kafka system consumer
2015-02-28  Chris RiccominiSAMZA-579; don't drop SSPs when a topic metadata refres...
2015-02-12  Chris RiccominiSAMZA-522; upgrade to Kafka 0.8.2.0
2015-02-06  David ChenSAMZA-93; gradle check should fail if missing license...
2015-01-30  Yan FangSAMZA-503: refresh lag gauge even when not fetching...
2015-01-28  Navina RameshSAMZA-227; upgrade kafka producer to new java client
2014-12-22  Naveen SomasundaramSAMZA-226; auto-create changelogs
2014-12-15  Jakob HomanSAMZA-163: Remove mutable.ConcurrentMap when we stop...
2014-10-22  Chris RiccominiSAMZA-440; fix infinite loop in broker proxy when parti...
2014-09-16  David ChenSAMZA-412; replace assert calls in tests with appropria...
next