Мне нужно писать в разных концентраторах событий Azure в разных пространствах имен, используя приложение весенней загрузки. Как создать производителя с другой конфигурацией. Я нашел пример для kafka, но я не могу сделать это для лазурных центров событий. если кто-нибудь может поделиться любым рабочим примером, было бы здорово.
Я пробовал много решений, одно из которых:
String srvrCfg = "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"$ConnectionString\" password=\"Endpoint=sb://connection-string\"";
Map<String, Object> props = new HashMap<>();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "test.servicebus.windows.net:9093");
props.put(ProducerConfig.RETRIES_CONFIG, 0);
props.put(ProducerConfig.BATCH_SIZE_CONFIG, 16384);
props.put(ProducerConfig.LINGER_MS_CONFIG, 1);
props.put(ProducerConfig.BUFFER_MEMORY_CONFIG, 33554432);
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
props.put("security.protocol", "SASL_SSL");
props.put("sasl.mechanism", "PLAIN");
props.put("sasl.jaas.config", srvrCfg);
DefaultKafkaProducerFactory<String, ErrorDto> pf = new DefaultKafkaProducerFactory<>(props);
KafkaTemplate<String, ErrorDto> template = new KafkaTemplate<>(pf, true);
template.setDefaultTopic("test-event-hub");
template.sendDefault("key1", "dataToSend");