Dominar Kafka Streams y ksqlDB

Apéndice A. Configuración de Kafka Streams

Kafka Streams es altamente configurable, y los parámetros disponibles, así como sus valores por defecto, son un objetivo en movimiento. Por lo tanto, las propiedades de configuración enumeradas en este apéndice deben utilizarse como punto de partida para familiarizarte con los distintos parámetros de configuración, pero consulta la documentación oficial para obtener la información más reciente.

Gestión de la configuración

En este libro, hemos estado configurando aplicaciones Kafka Streams creando una instancia Properties, y estableciendo manualmente los distintos parámetros de configuración. Un ejemplo de esta estrategia se muestra en el siguiente código:

class App {

  public static void main(String[] args) {
    Topology topology = GreeterTopology.build();

    Properties config = new Properties();
    config.put(StreamsConfig.APPLICATION_ID_CONFIG, "dev-consumer");
    config.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka:9092");

    KafkaStreams streams = new KafkaStreams(topology, config);

    // ....
  }
}

Sin embargo, cuando llegue el momento de enviar tu aplicación a producción, deberías considerar la posibilidad de cargar la configuración desde un archivo, en lugar de codificar los valores directamente en tu aplicación. Poder hacer cambios en la configuración sin tocar el código es menos propenso a errores, y si el archivo de configuración puede anularse en tiempo de ejecución (por ejemplo, medianteuna banderadel sistema ), entonces es extremadamente ...