Google Git
Sign in
apache / openwhisk-package-kafka / HEAD
  1. 20aa14c add logging for errors (#239) by Adnan Baruni · 6 years ago 1.4.3
  2. b2ffb77 Adjust threshold of authentication errors with brokers before disabling consumer (#238) by Adnan Baruni · 6 years ago
  3. 59d3b58 disable consumer after 5 failed attempts to connect to kafka brokers (#236) by Adnan Baruni · 6 years ago 1.4.2
  4. 951c445 Update name of action linked to trigger to be unique to avoid failed cleaning up of assets at end of test (#235) by Adnan Baruni · 6 years ago
  5. 4824cb7 Fix travis 1212 (#232) by Carlos Santana · 6 years ago
  6. 77088f7 Update default retry when not using gradle (#233) by Adnan Baruni · 6 years ago
  7. b074137 make number of retries configurable via system property (#231) by Adnan Baruni · 6 years ago
  8. e292cd6 Add rule and action to trigger tests which rely upon activation records (#230) by Adnan Baruni · 6 years ago
  9. fee695a verify trigger fire responds with any successful status code (#229) by Adnan Baruni · 6 years ago 1.4.1
  10. 5919ad7 Fix failing web action tests (#228) by Adnan Baruni · 6 years ago
  11. 5de5e73 support updating feed parameters (#227) by Adnan Baruni · 6 years ago 1.4.0
  12. 66f55a4 move positive trigger get test to health class (#226) by Adnan Baruni · 6 years ago
  13. 7aa98d7 feed action should return parameters with the same names as those passed in (#225) by Adnan Baruni · 6 years ago
  14. 6c8389d add parameters as query parameters for get request (#224) by Adnan Baruni · 6 years ago
  15. 3fb980c Add ability to get trigger configuration and status (#217) by Adnan Baruni · 7 years ago 1.3.0
  16. 8530bf5 update test to delete artifacts. reformat with scalariform (#216) by Adnan Baruni · 7 years ago
  17. 387d3d4 Support multiple workers (#214) by Adnan Baruni · 7 years ago 1.2.0
  18. 0c6b5ea Prevent infinite exception loop in Service thread (#215) by James Dubee · 7 years ago 1.1.8
  19. 7ef6d97 Bump to gradle 4. (#192) by Markus Thömmes · 7 years ago 1.1.7
  20. 8f496f5 Return Requested Accept Type (#199) by James Dubee · 7 years ago
  21. 289671f Restart changes feed on all exceptions (#213) by Justin Berstler · 7 years ago 1.1.6
  22. 7c1e0c0 create development guide (#187) by Justin Berstler · 7 years ago
  23. 885954e Replace 'kafka_brokers_sasl' with the (correct) 'brokers' (#212) by Justin Berstler · 7 years ago
  24. dc913fc Produce action fixes (#202) by Justin Berstler · 7 years ago 1.1.5
  25. a84f8e1 exponential backoff on trigger fire retry (#209) by Justin Berstler · 7 years ago
  26. e323899 Better handle when the connection to the DB drops (#205) by Justin Berstler · 7 years ago
  27. 74d0447 Block until message is sent, or timeout (#204) by Justin Berstler · 7 years ago
  28. dd97002 Adjust api_version to match current kafka-python client (#203) by Justin Berstler · 7 years ago
  29. e4cf4c9 Specify KafkaProducer API Version to Avoid Lookup (#201) by James Dubee · 7 years ago
  30. 5dd783a Add a 1 second delay between test retries (#200) by Justin Berstler · 7 years ago 1.1.4
  31. dfb0ddb Do not attempt to share DB across multiple processes (#198) by Justin Berstler · 7 years ago 1.1.3
  32. 028088c Use one canary document per provider instance (#197) by Justin Berstler · 7 years ago
  33. 5069ea1 Fix infinite loop in error handling (#194) by Justin Berstler · 7 years ago 1.1.2
  34. d780580 Update remaining .scala files with ASF license and add README badge. (#196) by Matt Rutkowski · 7 years ago
  35. b707f5d Add ASF license to python files. (#191) by Matt Rutkowski · 7 years ago
  36. 2de1930 Update health test to take the full health URL (#188) by Justin Berstler · 7 years ago
  37. d33e233 automatically monitor and restore the health of the DB changes feed (#186) by Justin Berstler · 7 years ago 1.1.1
  38. 537ed49 Verify migration (#152) by Justin Berstler · 7 years ago
  39. 0d05dbf installKafka.sh should create/update the "messaging" package (#181) by Justin Berstler · 7 years ago
  40. d3f2c10 Test fixes (#180) by Justin Berstler · 7 years ago
  41. 2c1663b convert from threading to multiprocessing (#178) by Justin Berstler · 7 years ago
  42. b17d9bd Update to run scancode from incubator-openwhisk-utilities repo. (#179) by Matt Rutkowski · 7 years ago
  43. 7847b3d Implement provider redundancy (#160) by Justin Berstler · 7 years ago 1.1.0
  44. 9b0936a Ensure the payload size does not exceed the specified limit (#174) by Justin Berstler · 7 years ago 1.0.19
  45. c195b5e fix logging timestamp format (#175) by Justin Berstler · 7 years ago
  46. 8613585 update travis deployment (#172) by Carlos Santana · 7 years ago
  47. d888365 Allow health test to specify an option trigger name suffix (#169) by Justin Berstler · 7 years ago
  48. 610a8ca Disable triggers instead of deleting them (#168) by Justin Berstler · 7 years ago 1.0.18
  49. e368313 Reuse the basic health test trigger, if it already exists by Justin Berstler · 7 years ago
  50. 37fee4a Upgrade librdkafka.git to 0.9.5 (#165) by James Dubee · 7 years ago
  51. 169bde8 Add 502 and 504 to the list of status codes on which to retry by Justin Berstler · 7 years ago 1.0.17
  52. f18fdda Pin Python Producer Feeds to Python 3 (#157) by James Dubee · 7 years ago
  53. 6fcfaa1 Update Bad Broker Test by dubeejw · 7 years ago
  54. 477d4b0 Use If Statement to Detect When a Base64 Decoded Message is Empty by dubeejw · 7 years ago
  55. 39db31a Use Python 3 for Producer Feeds by dubeejw · 7 years ago
  56. 7fa7b8f Add retry behavior to the BasicHealthTest by Justin Berstler · 7 years ago
  57. 7fbb954 Use CouchDB view instead of retrieving all docs (#151) by Justin Berstler · 7 years ago 1.0.16
  58. 75e299c During tests, give the consumer time to initialize (#150) by Justin Berstler · 7 years ago
  59. a0c274c Increase test stability, esp tests that roundtrip to MH by Justin Berstler · 7 years ago
  60. 5c35438 Clean up test integration towards OpenWhisk (#145) by Jason Peterson · 7 years ago
  61. 62392c2 Fix minor errors in installation script usage comments by Justin Berstler · 7 years ago
  62. 5b74a24 Bump scalatest dependency by Jason Peterson · 7 years ago
  63. 1265186 Add a stress test by Justin Berstler · 7 years ago 1.0.15
  64. 643c20d Update to v0.9.4 of the kafka client libs by Justin Berstler · 7 years ago
  65. 54a4a19 install the kafkaProduce action for testing (#142) by Justin Berstler · 7 years ago
  66. 0b85620 produce actions should handle binary keys and values (#140) by Justin Berstler · 7 years ago 1.0.14
  67. b24b88b minor formatting fix to readme by Carlos Santana · 7 years ago
  68. 0c109ab Added an image and updated docs in README.md by Roman Kharkovski · 7 years ago
  69. 04addac Support Base64 Encoding of Binary Message Payloads (#132) by James Dubee · 7 years ago
  70. 53a2ded update readme with content from core repo (#139) by Carlos Santana · 7 years ago
  71. d950a10 Fix messageHubProduce.py Syntax Error (#137) by James Dubee · 7 years ago
  72. 7267177 Correct declared package in new Produce tests (#133) by Justin Berstler · 7 years ago
  73. b4835b9 Consolidate Message Hub initialization into KafkaUtils by Justin Berstler · 7 years ago
  74. bc69715 Update CONTRIBUTING.md by Matt Rutkowski · 7 years ago
  75. a96b498 Add Travis CI (#128) by James Dubee · 7 years ago
  76. c25202e Catch Exceptions During Trigger Record (#123) by James Dubee · 7 years ago
  77. 33072d2 Only Allow the Doctor to Remove Consumers from Consumer Collection (#124) by James Dubee · 7 years ago
  78. 88b6790 Increase timeout for docker HEALTHCHECK instruction by Justin Berstler · 7 years ago 1.0.13
  79. 9d2d323 Create LICENSE.txt by Matt Rutkowski · 7 years ago
  80. cda072b Create CONTRIBUTING.md by Matt Rutkowski · 7 years ago
  81. 17ce6dc Add Additional Test Cases (#122) by James Dubee · 7 years ago
  82. 5a2cf14 log the activation when successfully firing a trigger by Justin Berstler · 7 years ago
  83. c1219c2 Handle Trigger Hosts that do not Response (#95) by James Dubee · 7 years ago
  84. 09c7d40 Logging tweaks by Justin Berstler · 7 years ago 1.0.12
  85. e12b288 Prevent Race Condition on Consumer Delete (#116) by James Dubee · 7 years ago
  86. 31af4fb Automatically restart the container if the health endpoint fails by Justin Berstler · 7 years ago
  87. 2dddc9a Add Locks to Database (#114) by James Dubee · 7 years ago
  88. bf4c713 Use __OW_API_KEY environment variable instead of whisk.getAuthKey() by Justin Berstler · 7 years ago
  89. adb9ab4 Remove use of whisk object by Justin Berstler · 7 years ago
  90. 6801e17 Remove Requirement for API Key Parameter (#108) by James Dubee · 7 years ago 1.0.11
  91. 1d8b565 Make small tweaks for log forwarding by Justin Berstler · 7 years ago
  92. 2df4bb8 Query for Non-default Namespace (#103) by James Dubee · 7 years ago
  93. 4c39687 Ensure that the selected namespace is actually valid by Justin Berstler · 7 years ago 1.0.10
  94. 0941529 Do Not Use the Default Namespace by dubeejw · 7 years ago
  95. 043ccbf Add the test cases by Vincent Hou · 7 years ago
  96. d5b26aa Fix Root Project Name by dubeejw · 7 years ago
  97. a2cfc97 Add Test Infrastructure by Justin Berstler · 7 years ago
  98. f787ef3 Handle the case where params.endpoint already contains the protocol (#97) by Justin Berstler · 7 years ago 1.0.9
  99. 2a43c43 Accept a comma-separated array of strings for the kafa_broker_sasl parameter (#92) by Justin Berstler · 7 years ago 1.0.8
  100. 0b50bb9 Do not Allow Invalid Namespaces (#82) by James Dubee · 7 years ago 1.0.7