производители для лазурных центров событий в разных пространствах имен - PullRequest
0 голосов
/ 31 октября 2019

Мне нужно писать в разных концентраторах событий 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");
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...