root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity
kafka/streams
History
A. Sophie Blee-Goldman 83c616f706
KAFKA-9983: KIP-613: add INFO level e2e latency metrics (#8697) 
Add e2e latency metrics at the beginning and end of task topologies
as INFO-level processor-node-level metrics.

Implements: KIP-613
Reviewers: John Roesler <vvcephei@apache.org>, Andrew Choi <a24choi@edu.uwaterloo.ca>, Bruno Cadonna <cadonna@confluent.io>, Matthias J. Sax <matthias@confluent.io>
 		2020-05-27 15:55:29 -05:00
..
examples/src KAFKA-7523: Add ConnectedStoreProvider to Processor API (#6824) 2020-05-27 10:57:14 -07:00
quickstart Bump trunk to 2.6.0-SNAPSHOT (#8026) 2020-02-03 13:04:56 -05:00
src KAFKA-9983: KIP-613: add INFO level e2e latency metrics (#8697) 2020-05-27 15:55:29 -05:00
streams-scala KAFKA-10003: Mark KStream.through() as deprecated and update Scala API (#8679) 2020-05-22 08:41:28 -07:00
test-utils/src MINOR: consolidate processor context for active/standby (#8669) 2020-05-18 14:50:54 -07:00
upgrade-system-tests-10/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
upgrade-system-tests-11/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
upgrade-system-tests-20/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests MINOR: Streams upgrade system test cleanup (#7571) 2019-10-24 10:28:29 -04:00
upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
upgrade-system-tests-0100/src/test/java/org/apache/kafka/streams/tests MINOR: Streams upgrade system test cleanup (#7571) 2019-10-24 10:28:29 -04:00
upgrade-system-tests-0101/src/test/java/org/apache/kafka/streams/tests MINOR: Streams upgrade system test cleanup (#7571) 2019-10-24 10:28:29 -04:00
upgrade-system-tests-0102/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
upgrade-system-tests-0110/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
.gitignore KAFKA-4848: Fix retryWithBackoff deadlock issue 2017-03-20 21:56:15 -07:00