fixtures.ts 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. export const fetchKsqlDbTablesPayload: {
  2. tables: Dictionary<string>[];
  3. streams: Dictionary<string>[];
  4. } = {
  5. tables: [
  6. {
  7. type: 'TABLE',
  8. name: 'USERS',
  9. topic: 'users',
  10. keyFormat: 'KAFKA',
  11. valueFormat: 'AVRO',
  12. isWindowed: 'false',
  13. },
  14. {
  15. type: 'TABLE',
  16. name: 'USERS2',
  17. topic: 'users',
  18. keyFormat: 'KAFKA',
  19. valueFormat: 'AVRO',
  20. isWindowed: 'false',
  21. },
  22. ],
  23. streams: [
  24. {
  25. type: 'STREAM',
  26. name: 'KSQL_PROCESSING_LOG',
  27. topic: 'default_ksql_processing_log',
  28. keyFormat: 'KAFKA',
  29. valueFormat: 'JSON',
  30. isWindowed: 'false',
  31. },
  32. {
  33. type: 'STREAM',
  34. name: 'PAGEVIEWS',
  35. topic: 'pageviews',
  36. keyFormat: 'KAFKA',
  37. valueFormat: 'AVRO',
  38. isWindowed: 'false',
  39. },
  40. ],
  41. };
  42. export const ksqlCommandResponse = {
  43. header: 'Test header',
  44. columnNames: [
  45. 'type',
  46. 'name',
  47. 'topic',
  48. 'keyFormat',
  49. 'valueFormat',
  50. 'isWindowed',
  51. ],
  52. rows: [
  53. [
  54. 'STREAM',
  55. 'KSQL_PROCESSING_LOG',
  56. 'default_ksql_processing_log',
  57. 'KAFKA',
  58. 'JSON',
  59. 'false',
  60. ],
  61. ['STREAM', 'PAGEVIEWS', 'pageviews', 'KAFKA', 'AVRO', 'false'],
  62. ],
  63. };