Styjun

How to break 信じようとしていただけかも知れない into separate parts?

Is Bran literally the world's memory?

Sorting the characters in a utf-16 string in java

Why are two-digit numbers in Jonathan Swift's "Gulliver's Travels" (1726) written in "German style"?

Should man-made satellites feature an intelligent inverted "cow catcher"?

How to keep bees out of canned beverages?

Trying to enter the Fox's den

Can this water damage be explained by lack of gutters and grading issues?

How to ask rejected full-time candidates to apply to teach individual courses?

Does Prince Arnaud cause someone holding the Princess to lose?

Does the Pact of the Blade warlock feature allow me to customize the properties of the pact weapon I create?

Can a Knight grant Knighthood to another?

Can the van der Waals coefficients be negative in the van der Waals equation for real gases?

Can I ask an author to send me his ebook?

FME Console for testing

Etymology of 見舞い

How do I deal with an erroneously large refund?

How to know or convert AREA, PERIMETER units in QGIS

Providing direct feedback to a product salesperson

Why aren't road bike wheels tiny?

Why aren't these two solutions equivalent? Combinatorics problem

Does traveling In The United States require a passport or can I use my green card if not a US citizen?

How to create a command for the "strange m" symbol in latex?

Is there a verb for listening stealthily?

Can a Kafka Connector load its own name?

.everyoneloves__top-leaderboard:empty,.everyoneloves__mid-leaderboard:empty,.everyoneloves__bot-mid-leaderboard:empty height:90px;width:728px;box-sizing:border-box;

1

According to Kafka Documentation

Connector configurations are simple key-value mappings. For standalone
mode these are defined in a properties file and passed to the Connect
process on the command line.

Most configurations are connector dependent, so they can't be outlined
here. However, there are a few common options:

name - Unique name for the connector. Attempting to register again with the same name will fail.

I have 10 connectors running in standalone mode like this:

bin/connect-standalone.sh config/connect-standalone.properties connector1.properties connector2.properties ...

My question is can a connector load its own name at runtime?

Thanks in advance.

apache-kafka apache-kafka-connect

share|improve this question

edited Mar 22 at 15:39

wardziniak

2,2521617

asked Mar 22 at 14:10

NovemberlandNovemberland

3441624

add a comment | 

1

According to Kafka Documentation

Connector configurations are simple key-value mappings. For standalone
mode these are defined in a properties file and passed to the Connect
process on the command line.

Most configurations are connector dependent, so they can't be outlined
here. However, there are a few common options:

name - Unique name for the connector. Attempting to register again with the same name will fail.

I have 10 connectors running in standalone mode like this:

bin/connect-standalone.sh config/connect-standalone.properties connector1.properties connector2.properties ...

My question is can a connector load its own name at runtime?

Thanks in advance.

apache-kafka apache-kafka-connect

share|improve this question

edited Mar 22 at 15:39

wardziniak

2,2521617

asked Mar 22 at 14:10

NovemberlandNovemberland

3441624

add a comment | 

According to Kafka Documentation

Connector configurations are simple key-value mappings. For standalone
mode these are defined in a properties file and passed to the Connect
process on the command line.

Most configurations are connector dependent, so they can't be outlined
here. However, there are a few common options:

name - Unique name for the connector. Attempting to register again with the same name will fail.

I have 10 connectors running in standalone mode like this:

bin/connect-standalone.sh config/connect-standalone.properties connector1.properties connector2.properties ...

My question is can a connector load its own name at runtime?

Thanks in advance.

apache-kafka apache-kafka-connect

share|improve this question

edited Mar 22 at 15:39

wardziniak

2,2521617

asked Mar 22 at 14:10

NovemberlandNovemberland

3441624

bin/connect-standalone.sh config/connect-standalone.properties connector1.properties connector2.properties ...

share|improve this question

edited Mar 22 at 15:39

wardziniak

2,2521617

asked Mar 22 at 14:10

NovemberlandNovemberland

3441624

share|improve this question

edited Mar 22 at 15:39

wardziniak

2,2521617

asked Mar 22 at 14:10

NovemberlandNovemberland

3441624

edited Mar 22 at 15:39

wardziniak

2,2521617

edited Mar 22 at 15:39

wardziniak

2,2521617

asked Mar 22 at 14:10

NovemberlandNovemberland

3441624

asked Mar 22 at 14:10

NovemberlandNovemberland

3441624

1 Answer
1

active

oldest

votes

1

Yes, you can get the name of the connector at runtime.

When connector starts all properties are passed to Connector::start(Map<String, String> props). Connector can read those properties, validate them, save and later pass to Task. It depends on Connector implementation if he use it or not.

Connector name property is name.

share|improve this answer

edited Mar 22 at 14:51

answered Mar 22 at 14:44

wardziniakwardziniak

2,2521617

• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  Thanks they are loaded via properties argument of "public void start(Map<String, String> props)" method of the connector task.
  
  – Novemberland
  Mar 27 at 11:57
  

  
  
  
  

add a comment | 

Your Answer

StackExchange.ifUsing("editor", function ()
StackExchange.using("externalEditor", function ()
StackExchange.using("snippets", function ()
StackExchange.snippets.init();
);
);
, "code-snippets");

StackExchange.ready(function()
var channelOptions =
tags: "".split(" "),
id: "1"
;
initTagRenderer("".split(" "), "".split(" "), channelOptions);

StackExchange.using("externalEditor", function()
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled)
StackExchange.using("snippets", function()
createEditor();
);

else
createEditor();

);

function createEditor()
StackExchange.prepareEditor(
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader:
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
,
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
);



);

draft saved

draft discarded

Sign up or log in

StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);

Sign up using Google

Sign up using Facebook

Sign up using Email and Password

Post as a guest

Name

Email

Required, but never shown

StackExchange.ready(
function ()
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f55301475%2fcan-a-kafka-connector-load-its-own-name%23new-answer', 'question_page');

);

Post as a guest

Name

Email

Required, but never shown

1

Yes, you can get the name of the connector at runtime.

When connector starts all properties are passed to Connector::start(Map<String, String> props). Connector can read those properties, validate them, save and later pass to Task. It depends on Connector implementation if he use it or not.

Connector name property is name.

share|improve this answer

edited Mar 22 at 14:51

answered Mar 22 at 14:44

wardziniakwardziniak

2,2521617

• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  Thanks they are loaded via properties argument of "public void start(Map<String, String> props)" method of the connector task.
  
  – Novemberland
  Mar 27 at 11:57
  

  
  
  
  

add a comment | 

1

Yes, you can get the name of the connector at runtime.

When connector starts all properties are passed to Connector::start(Map<String, String> props). Connector can read those properties, validate them, save and later pass to Task. It depends on Connector implementation if he use it or not.

Connector name property is name.

share|improve this answer

edited Mar 22 at 14:51

answered Mar 22 at 14:44

wardziniakwardziniak

2,2521617

• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  Thanks they are loaded via properties argument of "public void start(Map<String, String> props)" method of the connector task.
  
  – Novemberland
  Mar 27 at 11:57
  

  
  
  
  

add a comment | 

Yes, you can get the name of the connector at runtime.

When connector starts all properties are passed to Connector::start(Map<String, String> props). Connector can read those properties, validate them, save and later pass to Task. It depends on Connector implementation if he use it or not.

Connector name property is name.

share|improve this answer

edited Mar 22 at 14:51

answered Mar 22 at 14:44

wardziniakwardziniak

2,2521617

share|improve this answer

edited Mar 22 at 14:51

answered Mar 22 at 14:44

wardziniakwardziniak

2,2521617

answered Mar 22 at 14:44

wardziniakwardziniak

2,2521617

answered Mar 22 at 14:44

wardziniakwardziniak

2,2521617