admin/n8n-enterprise-unlocked
1
0
Fork 0
mirror of https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git synced 2025-12-17 01:56:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of https://github.com/n8n-io/n8n into n8n-io-master

Browse Source
This commit is contained in:
Ricardo Georgel
2021-07-16 11:28:08 -03:00
parent 7239e4f355 73edf05804
commit 9f4e18eb8d
252 changed files with 22348 additions and 2279 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
packages/nodes-base/nodes/Kafka/KafkaTrigger.node.ts
View File

@@ -95,6 +95,13 @@ export class KafkaTrigger implements INodeType {
default: false,
description: 'Allow sending message to a previously non exisiting topic .',
},
{
displayName: 'Read messages from beginning',
name: 'fromBeginning',
type: 'boolean',
default: true,
description: 'Read message from beginning .',
},
{
displayName: 'JSON Parse Message',
name: 'jsonParseMessage',
@@ -173,12 +180,12 @@ export class KafkaTrigger implements INodeType {
await consumer.connect();
await consumer.subscribe({ topic, fromBeginning: true });
const options = this.getNodeParameter('options', {}) as IDataObject;
await consumer.subscribe({ topic, fromBeginning: (options.fromBeginning)? true : false });
const self = this;
const options = this.getNodeParameter('options', {}) as IDataObject;
const useSchemaRegistry = this.getNodeParameter('useSchemaRegistry', 0) as boolean;
const schemaRegistryUrl = this.getNodeParameter('schemaRegistryUrl', 0) as string;