conditionally skip avro installation for arm macos

Signed-off-by: Krzysztof Milde <Krzysztof.Milde@Point72.com>

Author: mildek

.github/workflows/conda.yml

@@ -89,6 +89,11 @@ jobs:
             post-cleanup: 'all'
           if: ${{ runner.os != 'Windows' }}
 
+        - name: Install avrocpp (not available on osx-arm64)
+          run: micromamba install -y avrocpp
+          shell: micromamba-shell {0}
+          if: ${{ runner.os == 'Linux' }}
+
         - uses: mamba-org/setup-micromamba@v2
           with:
             micromamba-version: '2.3.2-0'

conda/dev-environment-unix.yml

@@ -4,7 +4,6 @@ channels:
   - nodefaults
 dependencies:
  - astor
- - avrocpp
  - bison
  - brotli
  - bump-my-version

cpp/cmake/modules/FindDepsKafkaAdapter.cmake

@@ -3,12 +3,19 @@ cmake_minimum_required(VERSION 3.7.2)
 if (CSP_USE_VCPKG)
   find_package(RdKafka CONFIG REQUIRED)
   find_package(unofficial-avro-cpp CONFIG REQUIRED)
+  set(CSP_HAVE_AVRO ON)
   if(NOT WIN32)
     # Bad, but a temporary workaround for
     # https://github.com/microsoft/vcpkg/issues/40320
     link_directories(${VCPKG_INSTALLED_DIR}/${VCPKG_TARGET_TRIPLET}/lib)
   endif()
 else()
   find_package(RdKafka REQUIRED)
-  find_package(Avro REQUIRED)
+  find_package(Avro QUIET)
+  if(Avro_FOUND)
+    set(CSP_HAVE_AVRO ON)
+  else()
+    set(CSP_HAVE_AVRO OFF)
+    message(STATUS "Avro not found - AVRO protocol support will be disabled")
+  endif()
 endif()

cpp/csp/adapters/kafka/CMakeLists.txt

@@ -24,11 +24,14 @@ find_package(DepsKafkaAdapter REQUIRED)
 
 target_link_libraries(csp_kafka_adapter PUBLIC csp_adapter_utils RdKafka::rdkafka RdKafka::rdkafka++)
 
-# Link Avro library - uses different target names for vcpkg vs conda
-if(CSP_USE_VCPKG)
-  target_link_libraries(csp_kafka_adapter PUBLIC unofficial::avro-cpp::avrocpp)
-else()
-  target_link_libraries(csp_kafka_adapter PUBLIC Avro::avrocpp)
+# Link Avro library if available
+if(CSP_HAVE_AVRO)
+  target_compile_definitions(csp_kafka_adapter PUBLIC CSP_HAVE_AVRO)
+  if(CSP_USE_VCPKG)
+    target_link_libraries(csp_kafka_adapter PUBLIC unofficial::avro-cpp::avrocpp)
+  else()
+    target_link_libraries(csp_kafka_adapter PUBLIC Avro::avrocpp)
+  endif()
 endif()
 
 install(TARGETS csp_kafka_adapter

cpp/csp/adapters/kafka/KafkaPublisher.cpp

@@ -3,7 +3,9 @@
 #include <csp/adapters/kafka/KafkaPublisher.h>
 #include <csp/adapters/utils/MessageWriter.h>
 #include <csp/adapters/utils/JSONMessageWriter.h>
+#ifdef CSP_HAVE_AVRO
 #include <csp/adapters/utils/AvroMessageWriter.h>
+#endif
 
 #include <librdkafka/rdkafkacpp.h>
 
@@ -18,8 +20,10 @@ KafkaPublisher::KafkaPublisher( KafkaAdapterManager * mgr, const Dictionary & pr
     auto protocol = properties.get<std::string>( "protocol" );
     if( protocol == "JSON" )
         m_msgWriter = std::make_shared<utils::JSONMessageWriter>( properties );
+#ifdef CSP_HAVE_AVRO
     else if( protocol == "AVRO" )
         m_msgWriter = std::make_shared<utils::AvroMessageWriter>( properties );
+#endif
     else if( protocol != "RAW_BYTES" )
         CSP_THROW( NotImplemented, "msg protocol " << protocol << " not currently supported for kafka output adapters" );
 }

cpp/csp/adapters/utils/CMakeLists.txt

@@ -1,5 +1,4 @@
 set(ADAPTER_UTILS_PUBLIC_HEADERS
-        AvroMessageWriter.h
         JSONMessageStructConverter.h
         JSONMessageWriter.h
         MessageEnums.h
@@ -10,6 +9,10 @@ set(ADAPTER_UTILS_PUBLIC_HEADERS
         ValueDispatcher.h
         )
 
+if(CSP_HAVE_AVRO)
+    list(APPEND ADAPTER_UTILS_PUBLIC_HEADERS AvroMessageWriter.h)
+endif()
+
 set(ADAPTER_UTILS_FILES
         JSONMessageStructConverter.cpp
         MessageWriter.cpp