이 구성 요소는 Apache Avro의 바이너리 데이터 포맷을 사용하여 메시지를 직렬화 및 역직렬화할 수 있는 avro에 대한 dataformat을 제공합니다. 또한 netty 또는 http를 통한 avro 사용을 위해 생산자 및 소비자 엔드포인트를 제공하여 Apache Avro의 rpc에 대한 지원을 제공합니다.
Maven 사용자는 이 구성 요소에 대해 pom.xml 에 다음 종속성을 추가해야 합니다.
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-avro</artifactId>
<version>x.x.x</version>
<!-- use the same version as your Camel core version -->
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-avro</artifactId>
<version>x.x.x</version>
<!-- use the same version as your Camel core version -->
</dependency>
Copy to ClipboardCopied!Toggle word wrapToggle overflow
Copy to ClipboardCopied!Toggle word wrapToggle overflow
maven, ant 등을 사용하여 스키마에서 클래스를 쉽게 생성할 수 있습니다. 자세한 내용은 Apache Avro 문서에서 확인할 수 있습니다.
그러나 스키마를 먼저 적용하지 않고 기존 클래스에 대한 스키마를 생성할 수 있습니다. 2.12 에서는 기존 프로토콜 인터페이스를 사용하여 RCP 호출을 수행할 수 있습니다. 프로토콜 자체에 인터페이스를 사용해야 하며 매개 변수 및 결과 유형에 대해 interface를 사용해야 합니다. 다음은 위의 스키마에 해당하는 클래스의 예입니다.
package org.apache.camel.avro.reflection;
public interface KeyValueProtocol {
void put(String key, Value value);
Value get(String key);
}
class Value {
private String value;
public String getValue() { return value; }
public void setValue(String value) { this.value = value; }
}
package org.apache.camel.avro.reflection;
public interface KeyValueProtocol {
void put(String key, Value value);
Value get(String key);
}
class Value {
private String value;
public String getValue() { return value; }
public void setValue(String value) { this.value = value; }
}
Copy to ClipboardCopied!Toggle word wrapToggle overflow