Update telemetry to capture Kafka Source (closes #8)

README.md

@@ -71,6 +71,7 @@ See the `examples/default` directory for a working usage example of this module.
 | <a name="input_eh_namespace_name"></a> [eh\_namespace\_name](#input\_eh\_namespace\_name) | The name of the Event Hubs namespace (note: if you are not using EventHubs leave this blank) | `string` | `""` | no |
 | <a name="input_enriched_topic_kafka_username"></a> [enriched\_topic\_kafka\_username](#input\_enriched\_topic\_kafka\_username) | Username for connection to Kafka cluster under PlainLoginModule (default: '$ConnectionString' which is used for EventHubs) | `string` | `"$ConnectionString"` | no |
 | <a name="input_java_opts"></a> [java\_opts](#input\_java\_opts) | Custom JAVA Options | `string` | `"-XX:InitialRAMPercentage=75 -XX:MaxRAMPercentage=75"` | no |
+| <a name="input_kafka_source"></a> [kafka\_source](#input\_kafka\_source) | The source providing the Kafka connectivity (def: azure\_event\_hubs) | `string` | `"azure_event_hubs"` | no |
 | <a name="input_ssh_ip_allowlist"></a> [ssh\_ip\_allowlist](#input\_ssh\_ip\_allowlist) | The comma-seperated list of CIDR ranges to allow SSH traffic from | `list(string)` | <pre>[<br>  "0.0.0.0/0"<br>]</pre> | no |
 | <a name="input_storage_container_path"></a> [storage\_container\_path](#input\_storage\_container\_path) | Path within the storage container to write output into | `string` | `"events/"` | no |
 | <a name="input_tags"></a> [tags](#input\_tags) | The tags to append to this resource | `map(string)` | `{}` | no |

main.tf

@@ -1,5 +1,7 @@
 locals {
-  module_name    = "lake-loader-vmss"
+  module_name_suffix = var.kafka_source == "azure_event_hubs" ? "" : ":${var.kafka_source}"
+
+  module_name    = "lake-loader-vmss${local.module_name_suffix}"
   module_version = "0.2.0"
 
   app_name = "lake-loader-azure"

variables.tf

@@ -164,6 +164,12 @@ variable "custom_iglu_resolvers" {
 
 # --- Telemetry
 
+variable "kafka_source" {
+  description = "The source providing the Kafka connectivity (def: azure_event_hubs)"
+  default     = "azure_event_hubs"
+  type        = string
+}
+
 variable "telemetry_enabled" {
   description = "Whether or not to send telemetry information back to Snowplow Analytics Ltd"
   type        = bool