[incubator-streampipes-extensions] 01/01: Merge remote-tracking branch 'origin/feature/latLngGeo' into feature/latLngGeo

[mi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

micklich pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git

commit cd0fc2a3736b845b5b48694fb03e629c9d31fe5f
Merge: d7f821d 370cdc6
Author: micklich <fl...@disy.net>
AuthorDate: Tue May 12 20:35:56 2020 +0200

    Merge remote-tracking branch 'origin/feature/latLngGeo' into feature/latLngGeo

 .../geo/jvm/jts/processor/latLngToGeo/LatLngToGeoController.java    | 6 ++++++
 1 file changed, 6 insertions(+)

diff --cc streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/latLngToGeo/LatLngToGeoController.java
index 747ffaf,d9a82c9..1df6aba
--- a/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/latLngToGeo/LatLngToGeoController.java
+++ b/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/latLngToGeo/LatLngToGeoController.java
@@@ -76,10 -77,10 +76,16 @@@ public class LatLngToGeoController exte
          .build();
    }
  
++        .supportedFormats(SupportedFormats.jsonFormat())
++        .supportedProtocols(SupportedProtocols.kafka())
++        .build();
++  }
  
    @Override
    public ConfiguredEventProcessor<LatLngToGeoParameter> onInvocation(DataProcessorInvocation graph, ProcessingElementParameterExtractor extractor) {
  
++  @Override
++  public ConfiguredEventProcessor<LatLngToGeoParameter> onInvocation(DataProcessorInvocation graph, ProcessingElementParameterExtractor extractor) {
  
      String lat = extractor.mappingPropertyValue(LAT_KEY);
      String lng = extractor.mappingPropertyValue(LNG_KEY);