Skip to content

Commit

Permalink
Align the name of the container from “broker” to “kafka”
Browse files Browse the repository at this point in the history
  • Loading branch information
joerg-wille authored and fhussonnois committed Sep 12, 2024
1 parent 8ad0409 commit 82c41cb
Show file tree
Hide file tree
Showing 7 changed files with 14 additions and 14 deletions.
8 changes: 4 additions & 4 deletions docs/content/en/docs/Getting started/_index.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
---
date: 2022-06-06
date: 2024-09-09
title: "Getting Started"
linkTitle: "Getting Started"
weight: 10
Expand Down Expand Up @@ -69,7 +69,7 @@ curl -X GET http://localhost:8083/connectors/connect-file-pulse-quickstart-log4j
$ docker exec -it -e KAFKA_OPTS="" connect kafka-avro-console-consumer \
--topic connect-file-pulse-quickstart-log4j \
--from-beginning \
--bootstrap-server broker:29092 \
--bootstrap-server kafka:29092 \
--property schema.registry.url=http://schema-registry:8081
```

Expand All @@ -91,7 +91,7 @@ Connect File Pulse use an internal topic to track the current state of files bei
$ docker exec -it -e KAFKA_OPTS="" connect kafka-console-consumer \
--topic connect-file-pulse-status \
--from-beginning \
--bootstrap-server broker:29092
--bootstrap-server kafka:29092
```

(output)
Expand Down Expand Up @@ -146,7 +146,7 @@ docker logs --tail="all" -f connect | grep "source task is transitioning to IDLE
$ docker exec -it connect kafka-avro-console-consumer \
--topic connect-file-pulse-quickstart-csv \
--from-beginning \
--bootstrap-server broker:29092 \
--bootstrap-server kafka:29092 \
--property schema.registry.url=http://schema-registry:8081
```

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,9 +19,9 @@
"topic": "connect-file-pulse-quickstart-csv",
"tasks.reader.class": "io.streamthoughts.kafka.connect.filepulse.fs.reader.LocalRowFileInputReader",
"tasks.file.status.storage.class": "io.streamthoughts.kafka.connect.filepulse.state.KafkaFileObjectStateBackingStore",
"tasks.file.status.storage.bootstrap.servers": "broker:29092",
"tasks.file.status.storage.bootstrap.servers": "kafka:29092",
"tasks.file.status.storage.topic": "connect-file-pulse-status",
"tasks.file.status.storage.topic.partitions": 10,
"tasks.file.status.storage.topic.replication.factor": 1,
"tasks.max": 1
}
}
4 changes: 2 additions & 2 deletions examples/connect-file-pulse-quickstart-avro.json
Original file line number Diff line number Diff line change
Expand Up @@ -10,9 +10,9 @@
"topic": "connect-file-pulse-quickstart-avro",
"tasks.reader.class": "io.streamthoughts.kafka.connect.filepulse.fs.reader.LocalAvroFileInputReader",
"tasks.file.status.storage.class": "io.streamthoughts.kafka.connect.filepulse.state.KafkaFileObjectStateBackingStore",
"tasks.file.status.storage.bootstrap.servers": "broker:29092",
"tasks.file.status.storage.bootstrap.servers": "kafka:29092",
"tasks.file.status.storage.topic": "connect-file-pulse-status",
"tasks.file.status.storage.topic.partitions": 10,
"tasks.file.status.storage.topic.replication.factor": 1,
"tasks.max": 1
}
}
2 changes: 1 addition & 1 deletion examples/connect-file-pulse-quickstart-csv.json
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@
"topic": "connect-file-pulse-quickstart-csv",
"tasks.reader.class": "io.streamthoughts.kafka.connect.filepulse.fs.reader.LocalRowFileInputReader",
"tasks.file.status.storage.class": "io.streamthoughts.kafka.connect.filepulse.state.KafkaFileObjectStateBackingStore",
"tasks.file.status.storage.bootstrap.servers": "broker:29092",
"tasks.file.status.storage.bootstrap.servers": "kafka:29092",
"tasks.file.status.storage.topic": "connect-file-pulse-status",
"tasks.file.status.storage.topic.partitions": 10,
"tasks.file.status.storage.topic.replication.factor": 1,
Expand Down
4 changes: 2 additions & 2 deletions examples/connect-file-pulse-quickstart-log4j.json
Original file line number Diff line number Diff line change
Expand Up @@ -22,9 +22,9 @@
"topic": "connect-file-pulse-quickstart-log4j",
"tasks.reader.class": "io.streamthoughts.kafka.connect.filepulse.fs.reader.LocalRowFileInputReader",
"tasks.file.status.storage.class": "io.streamthoughts.kafka.connect.filepulse.state.KafkaFileObjectStateBackingStore",
"tasks.file.status.storage.bootstrap.servers": "broker:29092",
"tasks.file.status.storage.bootstrap.servers": "kafka:29092",
"tasks.file.status.storage.topic": "connect-file-pulse-status",
"tasks.file.status.storage.topic.partitions": 10,
"tasks.file.status.storage.topic.replication.factor": 1,
"tasks.max": 1
}
}
2 changes: 1 addition & 1 deletion examples/connect-file-pulse-quickstart-raw.json
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
"topic": "connect-file-pulse-quickstart-csv",
"tasks.reader.class": "io.streamthoughts.kafka.connect.filepulse.fs.reader.LocalBytesArrayInputReader",
"tasks.file.status.storage.class": "io.streamthoughts.kafka.connect.filepulse.state.KafkaFileObjectStateBackingStore",
"tasks.file.status.storage.bootstrap.servers": "broker:29092",
"tasks.file.status.storage.bootstrap.servers": "kafka:29092",
"tasks.file.status.storage.topic": "connect-file-pulse-status",
"tasks.file.status.storage.topic.partitions": 10,
"tasks.file.status.storage.topic.replication.factor": 1,
Expand Down
4 changes: 2 additions & 2 deletions examples/connect-file-pulse-quickstart-xml.json
Original file line number Diff line number Diff line change
Expand Up @@ -12,9 +12,9 @@
"reader.xml.parser.namespace.aware.enabled": true,
"reader.xml.exclude.empty.elements": true,
"tasks.file.status.storage.class": "io.streamthoughts.kafka.connect.filepulse.state.KafkaFileObjectStateBackingStore",
"tasks.file.status.storage.bootstrap.servers": "broker:29092",
"tasks.file.status.storage.bootstrap.servers": "kafka:29092",
"tasks.file.status.storage.topic": "connct-file-pulse-status",
"tasks.file.status.storage.topic.partitions": 10,
"tasks.file.status.storage.topic.replication.factor": 1,
"tasks.max": 1
}
}

0 comments on commit 82c41cb

Please sign in to comment.