홈
제품
Red Hat build of Apache Camel
4.10
Kamelets reference for Red Hat build of Apache Camel for Quarkus
Chapter 50. Kafka Source

이 콘텐츠는 선택한 언어로 제공되지 않습니다.

Chapter 50. Kafka Source

Receive data from Kafka topics through Plain Login Module.

50.1. Configuration Options
링크 복사

The following table summarizes the configuration options available for the kafka-source Kamelet:

Expand

Property	Name	Description	Type	Default	Example
bootstrapServers *	Bootstrap Servers	Comma separated list of Kafka Broker URLs	string
password *	Password	Password to authenticate to kafka	string
topic *	Topic Names	Comma separated list of Kafka topic names	string
user *	Username	Username to authenticate to Kafka	string
allowManualCommit	Allow Manual Commit	Whether to allow doing manual commits	boolean	False
autoCommitEnable	Auto Commit Enable	If true, periodically commit to ZooKeeper the offset of messages already fetched by the consumer	boolean	True
autoOffsetReset	Auto Offset Reset	What to do when there is no initial offset. There are 3 enums and the value can be one of latest, earliest, none	string	latest
consumerGroup	Consumer Group	A string that uniquely identifies the group of consumers to which this source belongs	string		my-group-id
deserializeHeaders	Automatically Deserialize Headers	When enabled the Kamelet source will deserialize all message headers to String representation.	boolean	True
pollOnError	Poll On Error Behavior	What to do if kafka threw an exception while polling for new messages. There are 5 enums and the value can be one of `DISCARD`, `ERROR_HANDLER`, `RECONNECT`, `RETRY`, `STOP`	string	ERROR_HANDLER
saslMechanism	SASL Mechanism	The Simple Authentication and Security Layer (SASL) Mechanism used.	string	PLAIN
securityProtocol	Security Protocol	Protocol used to communicate with brokers. SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported	string	SASL_SSL
topicIsPattern	Topic Is Pattern	Whether the topic is a pattern (regular expression). This can be used to subscribe to dynamic number of topics matching the pattern.	boolean	False

* = Fields marked with an asterisk are mandatory.

50.2. Dependencies
링크 복사

50.2.1. Quarkus dependencies
링크 복사

<dependencies>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifact>camel-quarkus-core</artifact>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifact>camel-quarkus-kafka</artifact>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifact>camel-quarkus-kamelet</artifact>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.kamelets</groupId>
    <artifact>camel-kamelets-utils</artifact>
    <version>4.8.5</version>
  </dependency>
</dependencies>

<dependencies>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifact>camel-quarkus-core</artifact>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifact>camel-quarkus-kafka</artifact>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifact>camel-quarkus-kamelet</artifact>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.kamelets</groupId>
    <artifact>camel-kamelets-utils</artifact>
    <version>4.8.5</version>
  </dependency>
</dependencies>

Copy to Clipboard

Toggle word wrap

50.3. Usage
링크 복사

50.3.1. Camel JBang usage
링크 복사

50.3.1.1. Prerequisites for JBang
링크 복사

Install JBang.
You have executed the following command:
```
jbang app install camel@apache/camel
```
```
jbang app install camel@apache/camel
```
Copy to Clipboard Toggle word wrap

50.3.1.2. Running a route with JBang
링크 복사

Suppose you have a file named route.yaml with this content:

- route:
    from:
      uri: "kamelet:timer-source"
      parameters:
        period: 10000
        message: 'test'
      steps:
        - to:
            uri: "kamelet:log-sink"

- route:
    from:
      uri: "kamelet:timer-source"
      parameters:
        period: 10000
        message: 'test'
      steps:
        - to:
            uri: "kamelet:log-sink"

Copy to Clipboard

Toggle word wrap

You can now run it directly through the following command.

camel run route.yaml

camel run route.yaml

Copy to Clipboard

Toggle word wrap

50.3.2. Knative Source
링크 복사

You can use the kafka-source Kamelet as a Knative source by binding it to a Knative object.

kafka-source-binding.yaml

apiVersion: camel.apache.org/v1
kind: Pipe
metadata:
  name: kafka-source-binding
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1
      name: kafka-source
    properties:
      bootstrapServers: "The Brokers"
      password: "The Password"
      topic: "The Topic Names"
      user: "The Username"
  sink:
    ref:
      kind: Channel
      apiVersion: messaging.knative.dev/v1
      name: mychannel

apiVersion: camel.apache.org/v1
kind: Pipe
metadata:
  name: kafka-source-binding
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1
      name: kafka-source
    properties:
      bootstrapServers: "The Brokers"
      password: "The Password"
      topic: "The Topic Names"
      user: "The Username"
  sink:
    ref:
      kind: Channel
      apiVersion: messaging.knative.dev/v1
      name: mychannel

Copy to Clipboard

Toggle word wrap

50.3.3. Kafka Source
링크 복사

You can use the kafka-source Kamelet as a Kafka source by binding it to a Kafka topic.

kafka-source-binding.yaml

apiVersion: camel.apache.org/v1
kind: Pipe
metadata:
  name: kafka-source-binding
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1
      name: kafka-source
    properties:
      bootstrapServers: "The Brokers"
      password: "The Password"
      topic: "The Topic Names"
      user: "The Username"
  sink:
    ref:
      kind: KafkaTopic
      apiVersion: kafka.strimzi.io/v1beta1
      name: my-topic

apiVersion: camel.apache.org/v1
kind: Pipe
metadata:
  name: kafka-source-binding
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1
      name: kafka-source
    properties:
      bootstrapServers: "The Brokers"
      password: "The Password"
      topic: "The Topic Names"
      user: "The Username"
  sink:
    ref:
      kind: KafkaTopic
      apiVersion: kafka.strimzi.io/v1beta1
      name: my-topic

Copy to Clipboard

Toggle word wrap

50.4. Kamelets source file
링크 복사

https://github.com/jboss-fuse/camel-kamelets/blob/camel-kamelets-4.10.3-branch/kamelets/kafka-source.kamelet.yaml

이 콘텐츠는 선택한 언어로 제공되지 않습니다.

Chapter 50. Kafka Source

50.1. Configuration Options
링크 복사

50.2. Dependencies
링크 복사

50.2.1. Quarkus dependencies
링크 복사

50.3. Usage
링크 복사

50.3.1. Camel JBang usage
링크 복사

50.3.1.1. Prerequisites for JBang
링크 복사

50.3.1.2. Running a route with JBang
링크 복사

50.3.2. Knative Source
링크 복사

50.3.3. Kafka Source
링크 복사

50.4. Kamelets source file
링크 복사

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat 소개

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

이 콘텐츠는 선택한 언어로 제공되지 않습니다.

Chapter 50. Kafka Source

50.1. Configuration Options링크 복사링크가 클립보드에 복사되었습니다!

50.2. Dependencies링크 복사링크가 클립보드에 복사되었습니다!

50.2.1. Quarkus dependencies링크 복사링크가 클립보드에 복사되었습니다!

50.3. Usage링크 복사링크가 클립보드에 복사되었습니다!

50.3.1. Camel JBang usage링크 복사링크가 클립보드에 복사되었습니다!

50.3.1.1. Prerequisites for JBang링크 복사링크가 클립보드에 복사되었습니다!

50.3.1.2. Running a route with JBang링크 복사링크가 클립보드에 복사되었습니다!

50.3.2. Knative Source링크 복사링크가 클립보드에 복사되었습니다!

50.3.3. Kafka Source링크 복사링크가 클립보드에 복사되었습니다!

50.4. Kamelets source file링크 복사링크가 클립보드에 복사되었습니다!

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat 소개

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

50.1. Configuration Options
링크 복사

50.2. Dependencies
링크 복사

50.2.1. Quarkus dependencies
링크 복사

50.3. Usage
링크 복사

50.3.1. Camel JBang usage
링크 복사

50.3.1.1. Prerequisites for JBang
링크 복사

50.3.1.2. Running a route with JBang
링크 복사

50.3.2. Knative Source
링크 복사

50.3.3. Kafka Source
링크 복사

50.4. Kamelets source file
링크 복사