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

cdutz pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/plc4x.git


The following commit(s) were added to refs/heads/develop by this push:
     new deb7aa6  - Updated the fake kafka-connect config to one that matches 
other examples running in our IoT Lab
deb7aa6 is described below

commit deb7aa60f151b5158afa0f2149a7cd9851a88b8f
Author: Christofer Dutz <christofer.d...@c-ware.de>
AuthorDate: Tue Dec 3 11:04:02 2019 +0100

    - Updated the fake kafka-connect config to one that matches other examples 
running in our IoT Lab
---
 .../apache-kafka/config/plc4x-source.properties    | 48 +++++++++++-----------
 1 file changed, 24 insertions(+), 24 deletions(-)

diff --git a/plc4j/integrations/apache-kafka/config/plc4x-source.properties 
b/plc4j/integrations/apache-kafka/config/plc4x-source.properties
index e6246ab..24e4822 100644
--- a/plc4j/integrations/apache-kafka/config/plc4x-source.properties
+++ b/plc4j/integrations/apache-kafka/config/plc4x-source.properties
@@ -14,37 +14,37 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-name=plc-source-test
+name=plc-0
 connector.class=org.apache.plc4x.kafka.Plc4xSourceConnector
-
 default-topic=test
+tasks.max=2
 
-sources=machineA,machineB,machineC
+sources=machineA
 
-sources.machineA.connectionString=s7://1.2.3.4/1/1
+sources.machineA.connectionString=s7://10.10.64.20/1/1
 sources.machineA.jobReferences=s7-dashboard,s7-heartbeat
 sources.machineA.jobReferences.s7-heartbeat.topic=heartbeat
 
-sources.machineB.connectionString=s7://10.20.30.40/1/1
-sources.machineB.topic=heartbeat
-sources.machineB.jobReferences=s7-heartbeat
-
-sources.machineC.connectionString=ads://1.2.3.4.5.6
-sources.machineC.topic=heartbeat
-sources.machineC.jobReferences=ads-heartbeat
+jobs=s7-dashboard,s7-heartbeat
 
-jobs=s7-dashboard,s7-heartbeat,ads-heartbeat
+jobs.s7-dashboard.interval=1000
+jobs.s7-dashboard.fields=conveyorEntry,load,unload,transferLeft,transferRight,conveyorLeft,conveyorRight
+jobs.s7-dashboard.fields.conveyorEntry=%Q0.0:BOOL
+jobs.s7-dashboard.fields.load=%Q0.1:BOOL
+jobs.s7-dashboard.fields.unload=%Q0.2:BOOL
+jobs.s7-dashboard.fields.transferLeft=%Q0.3:BOOL
+jobs.s7-dashboard.fields.transferRight=%Q0.4:BOOL
+jobs.s7-dashboard.fields.conveyorLeft=%Q0.5:BOOL
+jobs.s7-dashboard.fields.conveyorRight=%Q0.6:BOOL
 
-jobs.s7-dashboard.interval=5000
-jobs.s7-dashboard.fields=inputPreasure,outputPreasure,temperature
-jobs.s7-dashboard.fields.inputPreasure=%DB.DB1.4:INT
-jobs.s7-dashboard.fields.outputPreasure=%Q1:BYT
-jobs.s7-dashboard.fields.temperature=%I3:INT
-
-jobs.s7-heartbeat.interval=1000
+jobs.s7-heartbeat.interval=500
 jobs.s7-heartbeat.fields=active
-jobs.s7-heartbeat.fields.active=%I0.2:BOOL
-
-jobs.ads-heartbeat.interval=1000
-jobs.ads-heartbeat.fields=active
-jobs.ads-heartbeat.fields.active=Main.running
\ No newline at end of file
+jobs.s7-heartbeat.fields.active=%Q0.1:BOOL
+
+bootstrap.servers=localhost:9092
+key.converter=org.apache.kafka.connect.json.JsonConverter
+value.converter=org.apache.kafka.connect.json.JsonConverter
+key.converter.schemas.enable=true
+value.converter.schemas.enable=true
+offset.storage.file.filename=/tmp/connect.offsets
+offset.flush.interval.ms=10000

Reply via email to