nuclearapk / simple-kafka_adapter Goto Github PK

RUN cmake .. &&     cmake --build .:
#13 0.294 -- The C compiler identification is GNU 13.1.0
#13 0.346 -- The CXX compiler identification is GNU 13.1.0
#13 0.353 -- Detecting C compiler ABI info
#13 0.401 -- Detecting C compiler ABI info - done
#13 0.408 -- Check for working C compiler: /usr/bin/cc - skipped
#13 0.408 -- Detecting C compile features
#13 0.409 -- Detecting C compile features - done
#13 0.411 -- Detecting CXX compiler ABI info
#13 0.477 -- Detecting CXX compiler ABI info - done
#13 0.485 -- Check for working CXX compiler: /usr/local/bin/c++ - skipped
#13 0.485 -- Detecting CXX compile features
#13 0.486 -- Detecting CXX compile features - done
#13 0.487 -- Configuring done
#13 0.489 -- Generating done
#13 0.490 -- Build files have been written to: /app/build
#13 0.518 [ 20%] Building CXX object CMakeFiles/SimpleKafka1C.dir/src/dllmain.cpp.o
#13 0.532 [ 40%] Building CXX object CMakeFiles/SimpleKafka1C.dir/src/exports.cpp.o
#13 0.995 [ 60%] Building CXX object CMakeFiles/SimpleKafka1C.dir/src/Component.cpp.o
#13 1.698 [ 80%] Building CXX object CMakeFiles/SimpleKafka1C.dir/src/SimpleKafka1C.cpp.o
#13 2.765 In file included from /usr/include/boost/bind.hpp:30,
#13 2.765                  from /usr/include/boost/property_tree/json_parser/detail/parser.hpp:7,
#13 2.765                  from /usr/include/boost/property_tree/json_parser/detail/read.hpp:13,
#13 2.765                  from /usr/include/boost/property_tree/json_parser.hpp:16,
#13 2.765                  from /app/src/SimpleKafka1C.cpp:4:
#13 2.765 /usr/include/boost/bind.hpp:36:1: note: '#pragma message: The practice of declaring the Bind placeholders (_1, _2, ...) in the global namespace is deprecated. Please use <boost/bind/bind.hpp> + using namespace boost::placeholders, or define BOOST_BIND_GLOBAL_PLACEHOLDERS to retain the current behavior.'
#13 2.765    36 | BOOST_PRAGMA_MESSAGE(
#13 2.765       | ^~~~~~~~~~~~~~~~~~~~
#13 3.019 In file included from /app/src/SimpleKafka1C.h:14,
#13 3.019                  from /app/src/SimpleKafka1C.cpp:8:
#13 3.019 /app/src/Component.h: In instantiation of 'void Component::AddMethod(const std::wstring&, const std::wstring&, C*, T (C::*)(Ts ...), std::map<long int, std::variant<std::monostate, int, double, bool, std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> >, tm, std::vector<char, std::allocator<char> > > >&&) [with T = long int; C = SimpleKafka1C; Ts = {}; std::wstring = std::__cxx11::basic_string<wchar_t>]':
#13 3.019 /app/src/SimpleKafka1C.cpp:110:14:   required from here
#13 3.019 /app/src/Component.h:213:46: error: could not convert 'std::apply<long int (SimpleKafka1C::* const&)(), tuple<SimpleKafka1C*> >(f, std::tuple_cat(_Tpls&& ...) [with _Tpls = {tuple<SimpleKafka1C*>, tuple<>&}; <template-parameter-1-2> = void; typename __tuple_cat_result<_Tpls ...>::__type = __tuple_cat_result<tuple<SimpleKafka1C*>, tuple<>&>::__type](args))' from 'long int' to 'variant_t' {aka 'std::variant<std::monostate, int, double, bool, std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char> >, tm, std::vector<char, std::allocator<char> > >'}
#13 3.019   213 |                             return std::apply(f, std::tuple_cat(std::make_tuple(c), args));
#13 3.019       |                                    ~~~~~~~~~~^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
#13 3.019       |                                              |
#13 3.019       |                                              long int
#13 3.442 gmake[2]: *** [CMakeFiles/SimpleKafka1C.dir/build.make:118: CMakeFiles/SimpleKafka1C.dir/src/SimpleKafka1C.cpp.o] Error 1
#13 3.442 gmake[1]: *** [CMakeFiles/Makefile2:83: CMakeFiles/SimpleKafka1C.dir/all] Error 2
#13 3.442 gmake: *** [Makefile:91: all] Error 2
------
executor failed running [/bin/sh -c cmake .. &&     cmake --build .]: exit code: 2

RUN apt-get update && \
    apt-get install -y \
      libboost-dev libboost-program-options-dev \
      libgtest-dev \
      cmake \
      librdkafka-dev

FROM gcc:latest as build

RUN apt-get update && \
    apt-get install -y \
      libboost-dev libboost-program-options-dev \
      libgtest-dev \
      cmake \
      librdkafka-dev

ADD ./src /app/src
ADD ./lib /app/lib
ADD ./include /app/include
ADD ./CMakeLists.txt /app/CMakeLists.txt

WORKDIR /app/build

RUN cmake .. && \
    cmake --build . 

Компонента.УстановитьПараметр("security.protocol", "SASL_SSL");
Компонента.УстановитьПараметр("ssl.truststore.location", НастройкиПодключения.SslTruststoreLocation);
Компонента.УстановитьПараметр("ssl.truststore.password", НастройкиПодключения.SslTruststorePassword);
Компонента.УстановитьПараметр("ssl.keystore.location", НастройкиПодключения.SslKeystoreLocation);
Компонента.УстановитьПараметр("ssl.keystore.password", НастройкиПодключения.SslKeystorePassword);
Компонента.УстановитьПараметр("ssl.key.password", НастройкиПодключения.SslKeyPassword);
Компонента.УстановитьПараметр("sasl.mechanism", "PLAIN");
Компонента.УстановитьПараметр("sasl.jaas.config", "org.apache.kafka.common.security.plain.PlainLoginModule required username=""" + НастройкиПодключения.SaslUser + """ password=""" + НастройкиПодключения.SaslPassword + """");

2023-05-17 20:27:15.568: Java TrustStores are not supported, use `ssl.ca.location` and a certificate file instead. See https://github.com/edenhill/librdkafka/wiki/Using-SSL-with-librdkafka for more information.
2023-05-17 20:31:39.769: Java JAAS configuration is not supported, see https://github.com/edenhill/librdkafka/wiki/Using-SASL-with-librdkafka for more information.

Компонента = СоздатьКомпонентуКафкаКлиент();
	Если Компонента = Неопределено Тогда
		Возврат;
	КонецЕсли;
	
	СтруктураПодключения = РегламентныхЗаданийОбщий.ПолучитьСтруктуруПодключения("_ЗаписьКафка");
	
	Если ТипЗнч(Данные) <> Тип("Массив") Тогда
		Сообщения = ОбщегоНазначенияКлиентСервер.ЗначениеВМассиве(Данные);
	Иначе
		Сообщения = Данные;
	КонецЕсли;
	
	Если СтруктураПодключения.Параметры.Свойство("КаталогЛогов")
		И ЗначениеЗаполнено(СтруктураПодключения.Параметры.КаталогЛогов) Тогда
		Компонента.КаталогЛогов = СтруктураПодключения.Параметры.КаталогЛогов;
	КонецЕсли;
	
	Брокеры = СтрЗаменить(СтруктураПодключения.Хост, "http://", "");
	Топик = СтруктураПодключения.Параметры.ИмяТопика;
	// инициализируем подключение к брокеру
	// достаточно указать одного брокера из кластера, либо есть возможность перечислить брокеров через ,
	РезультатИнициализации = Компонента.ИнициализироватьПродюсера(Брокеры);
	
	Если РезультатИнициализации Тогда
		Для Каждого СообщениеВКафку Из Сообщения Цикл
			// Parametr1 - Тело сообщения (строка)
			// Parametr2 - Топик (строка)
			// Parametr3 - Номер партиции, по умолчанию = -1 (число)
			// Parametr4 - Произвольный ключ, идентифицирующий сообщение, например GUID (строка)
			// Parametr5 - Заголовки (строка), "ключ1,значение1;ключ2,значение2"
			ИДТранзакции = Строка(Новый УникальныйИдентификатор);
			Заголовки = ""; //"key1,test1;key2,test2";
			РезультатОтправки = Компонента.ОтправитьСообщение(СообщениеВКафку, Топик, 0, ИДТранзакции, Заголовки);
			Если Не РезультатОтправки Тогда
				ТекстОшибки = ПодробноеПредставлениеОшибки(ИнформацияОбОшибке());
				ЗаписьЖурналаРегистрации(Компонента.ПолучитьСообщениеОбОшибке(),
					УровеньЖурналаРегистрации.Ошибка
					,
					,
					ТекстОшибки); 
			КонецЕсли;
		КонецЦикла;
		Компонента.ОстановитьПродюсера();
		Компонента = Неопределено;
	КонецЕсли;
КонецПроцедуры

2024-02-07 15:02:51.818740028 Info: initProducer. brokers-хх.ххх.ххх.ххх:ххххх
2024-02-07 15:02:51.820222781 Info: produceAvro. TopicName-order-exchange-query-dev currentPartition-0 avroFile.size()- 0
2024-02-07 15:02:51.820285859 Info: produce. Success

Компонента.ОстановитьКонсьюмера();