Creator "Biz.KActivity GML Exporter"
Version 1
graph
[
	directed 0
	node
	[
		id "49df51d8-b488-4934-844c-19f8e9c6f868"
		name "JdbcSourceConnector"
		className "io.confluent.connect.jdbc.JdbcSourceConnector"
		type "source"
		x "0.0"
		y "0.0"
		content "{
  'connector.class': 'io.confluent.connect.jdbc.JdbcSourceConnector',
  'timestamp.column.name': '',
  'incrementing.column.name': 'discountID',
  'validate.non.null': 'true',
  'tasks.max': '1',
  'query': 'SELECT TOP 1 * FROM DISCOUNT',
  'batch.max.rows': '100',
  'timestamp.delay.interval.ms': '0',
  'table.types': 'TABLE',
  'table.blacklist': '',
  'table.poll.interval.ms': '6000',
  'table.whitelist': '',
  'mode': 'incrementing',
  'value.converter.schema.registry.url': 'http://localhost:8081',
  'topic.prefix': 'DISCOUNT',
  'schema.pattern': '',
  'poll.interval.ms': '5000',
  'name': 'Forcive-DISCOUNT',
  'connection.url': 'jdbc:sqlserver://192.168.1.200\\MSSQLSERVER2012;user=sa2;password=ZAQ!2wsx;database=LOCATION_ACTIVITY_DB',
  'key.converter.schema.registry.url': 'http://localhost:8081'
}"
	]
	node
	[
		id "452445cc-be82-45a0-ab9e-6800d7882442"
		name "JdbcSourceConnector"
		className "io.confluent.connect.jdbc.JdbcSourceConnector"
		type "source"
		x "0.0"
		y "0.0"
		content "{
  'connector.class': 'io.confluent.connect.jdbc.JdbcSourceConnector',
  'timestamp.column.name': '',
  'incrementing.column.name': 'guestCheckLineItemID',
  'validate.non.null': 'true',
  'tasks.max': '1',
  'query': 'SELECT TOP 1 * FROM GUEST_CHECK_LINE_ITEM_HIST',
  'batch.max.rows': '100',
  'timestamp.delay.interval.ms': '0',
  'table.types': 'TABLE',
  'table.blacklist': '',
  'table.poll.interval.ms': '6000',
  'table.whitelist': '',
  'mode': 'incrementing',
  'value.converter.schema.registry.url': 'http://localhost:8081',
  'topic.prefix': 'GUEST_CHECK_LINE_ITEM_HIST',
  'schema.pattern': '',
  'poll.interval.ms': '5000',
  'name': 'Forcive-GUEST_CHECK_LINE_ITEM_HIST',
  'connection.url': 'jdbc:sqlserver://192.168.1.200\\MSSQLSERVER2012;user=sa2;password=ZAQ!2wsx;database=LOCATION_ACTIVITY_DB',
  'key.converter.schema.registry.url': 'http://localhost:8081'
}"
	]
	node
	[
		id "4c38f566-d26b-413c-997d-84b6a4ea5e45"
		name "Forcive.ForciveActivity"
		className "Forcive.ForciveActivity"
		type "activity"
		x "0.0"
		y "0.0"
		content "{  'name': 'Forcive.ForciveActivity',
  'query': 'SELECT DISCOUNT.discountID, DISCOUNT.name, GUEST_CHECK_LINE_ITEM_HIST.guestCheckID , GUEST_CHECK_LINE_ITEM_HIST.referenceInfo FROM KSTREAM(DISCOUNT) INNER JOIN KSTREAM(GUEST_CHECK_LINE_ITEM_HIST) ON DISCOUNT.organizationID = GUEST_CHECK_LINE_ITEM_HIST.organizationID',
  'join.window': '60000',
  'topic.result': 'topic_result',
}"
	]
	node
	[
		id "fbc719f0-2f00-4e81-bc6e-573cb6fd92c2"
		name "ForciveSinkConnector"
		className "Forcive.Kafka.ForciveSinkConnector"
		type "source"
		x "0.0"
		y "0.0"
		content "{
  'name': 'ForciveSinkConnector',
  'config': {
    'connector.class': 'Forcive.Kafka.ForciveSinkConnector',
    'topics': 'topic_output2-KEY-SELECT-repartition',
    'tasks.max': '1',
    'forcive.connect.url': '192.168.1.17',
    'forcive.connect.port': '26311',
    'forcive.connect.password': 'ZAQ12wsx',
    'forcive.message.queue.timeout': '100',
    'forcive.connect.user': 'TenancyAdministrator',
    'forcive.profile.name': 'Profile1',
    'key.converter': 'org.apache.kafka.connect.storage.StringConverter',
    'key.converter.schema.registry.url': 'http://192.168.1.163:8081',
    'value.converter': 'io.confluent.connect.avro.AvroConverter',
    'value.converter.schema.registry.url': 'http://192.168.1.163:8081',
    'forcive.batch.size' : '2147483647',
    'forcive.batch.auto.flush' : 'false',
    'forcive.fields.mapping': ' { \'relations\' : [ { \'from\' : \'DISCOUNT_discountID\', \'to\' : \'[sinkTest].[discountID]\' }, { \'from\' : \'DISCOUNT_name\', \'to\' : \'[sinkTest].[discountName]\' }, { \'from\' : \'GUEST_CHECK_LINITEM_HIST_guestCheckID\', \'to\' : \'[sinkTest].[guestCheckID]\' }, { \'from\' : \'GUEST_CHECK_LINE_ITEM_HIST_referenceInfo\', \'to\' : \'[sinkTest].[referenceInfo]\' } ] }'
  }
}"
	]
	edge
	[
		source "49df51d8-b488-4934-844c-19f8e9c6f868"
		target "4c38f566-d26b-413c-997d-84b6a4ea5e45"
	]
	edge
	[
		source "452445cc-be82-45a0-ab9e-6800d7882442"
		target "4c38f566-d26b-413c-997d-84b6a4ea5e45"
	]
	edge
	[
		source "4c38f566-d26b-413c-997d-84b6a4ea5e45"
		target "fbc719f0-2f00-4e81-bc6e-573cb6fd92c2"
	]
]