Styjun

Can a new player join a group only when a new campaign starts?

Fundamental Solution of the Pell Equation

Wu formula for manifolds with boundary

Is it common practice to audition new musicians one-on-one before rehearsing with the entire band?

How come Sam didn't become Lord of Horn Hill?

Trademark violation for app?

Is grep documentation wrong?

Does classifying an integer as a discrete log require it be part of a multiplicative group?

Denied boarding although I have proper visa and documentation. To whom should I make a complaint?

Is the Standard Deduction better than Itemized when both are the same amount?

How can I use the Python library networkx from Mathematica?

Should I use a zero-interest credit card for a large one-time purchase?

What do you call the main part of a joke?

Do I really need to have a message in a novel to appeal to readers?

Do square wave exist?

When a candle burns, why does the top of wick glow if bottom of flame is hottest?

Do jazz musicians improvise on the parent scale in addition to the chord-scales?

Extracting terms with certain heads in a function

What would be the ideal power source for a cybernetic eye?

How do I find out the mythology and history of my Fortress?

How to compare two different files line by line in unix?

Irreducible of finite Krull dimension implies quasi-compact?

How to deal with a team lead who never gives me credit?

How could we fake a moon landing now?

SSL KafkaAdminClient object using java.security.Keystore object

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

0

I need to create kafkaAmdinClient SSL object using java.security.keystore object.
i.e I have to read the keystore and truststire files from database as a clob and get the keystore in java.security.keystore object and use this to create Admin client object.

I am able to create AdminClient object using properties object :

props.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, trustStorePwd);
 props.put(SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG, "/ngs/app/bolt_components/kafka_ssl/RN_BC_YELLOWBIRD/client.truststore.jks");
 props.put(SslConfigs.SSL_KEYSTORE_PASSWORD_CONFIG, keyStorePwd);
 kafkaAdminClient = AdminClient.create(props);

But as per requiremtn i should not specify keystore file location. Instead specify keystore object.

KeyStoreDto kDto=KeystoreManager.getKafkaKeyStoreDto(kafkaDto.getKEYSTORE_ID());
 java.security.KeyStore keyStore = kDto.getKeyStore();
 java.security.KeyStore trustStore = kDto.getTrustStore();
 String keyStorePwd=kDto.getKeyStorePassword();
 String trustStorePwd=kDto.getTrustStorePassword();

From this i have to use keyStore and trustStore.

Can anyone help me with this.

ssl apache-kafka keystore truststore

share|improve this question

edited Mar 23 at 0:04

Giorgos Myrianthous

5,59731848

asked Mar 22 at 9:35

NehaGoswamiNehaGoswami

286

add a comment | 

0

I need to create kafkaAmdinClient SSL object using java.security.keystore object.
i.e I have to read the keystore and truststire files from database as a clob and get the keystore in java.security.keystore object and use this to create Admin client object.

I am able to create AdminClient object using properties object :

props.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, trustStorePwd);
 props.put(SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG, "/ngs/app/bolt_components/kafka_ssl/RN_BC_YELLOWBIRD/client.truststore.jks");
 props.put(SslConfigs.SSL_KEYSTORE_PASSWORD_CONFIG, keyStorePwd);
 kafkaAdminClient = AdminClient.create(props);

But as per requiremtn i should not specify keystore file location. Instead specify keystore object.

KeyStoreDto kDto=KeystoreManager.getKafkaKeyStoreDto(kafkaDto.getKEYSTORE_ID());
 java.security.KeyStore keyStore = kDto.getKeyStore();
 java.security.KeyStore trustStore = kDto.getTrustStore();
 String keyStorePwd=kDto.getKeyStorePassword();
 String trustStorePwd=kDto.getTrustStorePassword();

From this i have to use keyStore and trustStore.

Can anyone help me with this.

ssl apache-kafka keystore truststore

share|improve this question

edited Mar 23 at 0:04

Giorgos Myrianthous

5,59731848

asked Mar 22 at 9:35

NehaGoswamiNehaGoswami

286

add a comment | 

I need to create kafkaAmdinClient SSL object using java.security.keystore object.
i.e I have to read the keystore and truststire files from database as a clob and get the keystore in java.security.keystore object and use this to create Admin client object.

I am able to create AdminClient object using properties object :

props.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, trustStorePwd);
 props.put(SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG, "/ngs/app/bolt_components/kafka_ssl/RN_BC_YELLOWBIRD/client.truststore.jks");
 props.put(SslConfigs.SSL_KEYSTORE_PASSWORD_CONFIG, keyStorePwd);
 kafkaAdminClient = AdminClient.create(props);

But as per requiremtn i should not specify keystore file location. Instead specify keystore object.

KeyStoreDto kDto=KeystoreManager.getKafkaKeyStoreDto(kafkaDto.getKEYSTORE_ID());
 java.security.KeyStore keyStore = kDto.getKeyStore();
 java.security.KeyStore trustStore = kDto.getTrustStore();
 String keyStorePwd=kDto.getKeyStorePassword();
 String trustStorePwd=kDto.getTrustStorePassword();

From this i have to use keyStore and trustStore.

Can anyone help me with this.

ssl apache-kafka keystore truststore

share|improve this question

edited Mar 23 at 0:04

Giorgos Myrianthous

5,59731848

asked Mar 22 at 9:35

NehaGoswamiNehaGoswami

286

props.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, trustStorePwd);
 props.put(SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG, "/ngs/app/bolt_components/kafka_ssl/RN_BC_YELLOWBIRD/client.truststore.jks");
 props.put(SslConfigs.SSL_KEYSTORE_PASSWORD_CONFIG, keyStorePwd);
 kafkaAdminClient = AdminClient.create(props);

KeyStoreDto kDto=KeystoreManager.getKafkaKeyStoreDto(kafkaDto.getKEYSTORE_ID());
 java.security.KeyStore keyStore = kDto.getKeyStore();
 java.security.KeyStore trustStore = kDto.getTrustStore();
 String keyStorePwd=kDto.getKeyStorePassword();
 String trustStorePwd=kDto.getTrustStorePassword();

share|improve this question

edited Mar 23 at 0:04

Giorgos Myrianthous

5,59731848

asked Mar 22 at 9:35

NehaGoswamiNehaGoswami

286

share|improve this question

edited Mar 23 at 0:04

Giorgos Myrianthous

5,59731848

asked Mar 22 at 9:35

NehaGoswamiNehaGoswami

286

edited Mar 23 at 0:04

Giorgos Myrianthous

5,59731848

edited Mar 23 at 0:04

Giorgos Myrianthous

5,59731848

asked Mar 22 at 9:35

NehaGoswamiNehaGoswami

286

asked Mar 22 at 9:35

NehaGoswamiNehaGoswami

286

1 Answer
1

active

oldest

votes

0

Kafka does not support ssl using java.security.keystore object.
You can look into SslFactory class at kafka for more information.

share|improve this answer

answered Mar 23 at 4:27

Rohit YadavRohit Yadav

37728

• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  But i dont have a path here, i am reading clob (.jks fie) from databse. String keystore_pwd = PasswordService.INSTANCE.decrypt(result.getString("keystore_pwd")); dto.setKeyStorePassword(keystore_pwd); Blob blob = result.getBlob("keystore_file"); is = blob.getBinaryStream(); keyStore.load(is, keystore_pwd.toCharArray()); dto.setKeyStore(keyStore);
  
  – NehaGoswami
  Mar 25 at 7:47
  
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  that's mentioned kafka does not support this.
  
  – Rohit Yadav
  Mar 25 at 8:37
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  ok so is there any other way in which keystore.jks file can be used to create AdminClient object in Kafka through java code if keystore.jks is stored in DB? And workaround?
  
  – NehaGoswami
  Mar 25 at 8:52
  
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  Kafka doesn't support your requirement and there is no alternate for the same.I have provide the link of Kafka source code.You can go through.
  
  – Rohit Yadav
  Mar 25 at 9:54
  

  
  
  
  

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%2f55296657%2fssl-kafkaadminclient-object-using-java-security-keystore-object%23new-answer', 'question_page');

);

Post as a guest

Name

Email

Required, but never shown

0

Kafka does not support ssl using java.security.keystore object.
You can look into SslFactory class at kafka for more information.

share|improve this answer

answered Mar 23 at 4:27

Rohit YadavRohit Yadav

37728

• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  But i dont have a path here, i am reading clob (.jks fie) from databse. String keystore_pwd = PasswordService.INSTANCE.decrypt(result.getString("keystore_pwd")); dto.setKeyStorePassword(keystore_pwd); Blob blob = result.getBlob("keystore_file"); is = blob.getBinaryStream(); keyStore.load(is, keystore_pwd.toCharArray()); dto.setKeyStore(keyStore);
  
  – NehaGoswami
  Mar 25 at 7:47
  
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  that's mentioned kafka does not support this.
  
  – Rohit Yadav
  Mar 25 at 8:37
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  ok so is there any other way in which keystore.jks file can be used to create AdminClient object in Kafka through java code if keystore.jks is stored in DB? And workaround?
  
  – NehaGoswami
  Mar 25 at 8:52
  
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  Kafka doesn't support your requirement and there is no alternate for the same.I have provide the link of Kafka source code.You can go through.
  
  – Rohit Yadav
  Mar 25 at 9:54
  

  
  
  
  

add a comment | 

0

Kafka does not support ssl using java.security.keystore object.
You can look into SslFactory class at kafka for more information.

share|improve this answer

answered Mar 23 at 4:27

Rohit YadavRohit Yadav

37728

• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  But i dont have a path here, i am reading clob (.jks fie) from databse. String keystore_pwd = PasswordService.INSTANCE.decrypt(result.getString("keystore_pwd")); dto.setKeyStorePassword(keystore_pwd); Blob blob = result.getBlob("keystore_file"); is = blob.getBinaryStream(); keyStore.load(is, keystore_pwd.toCharArray()); dto.setKeyStore(keyStore);
  
  – NehaGoswami
  Mar 25 at 7:47
  
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  that's mentioned kafka does not support this.
  
  – Rohit Yadav
  Mar 25 at 8:37
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  ok so is there any other way in which keystore.jks file can be used to create AdminClient object in Kafka through java code if keystore.jks is stored in DB? And workaround?
  
  – NehaGoswami
  Mar 25 at 8:52
  
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  Kafka doesn't support your requirement and there is no alternate for the same.I have provide the link of Kafka source code.You can go through.
  
  – Rohit Yadav
  Mar 25 at 9:54
  

  
  
  
  

add a comment | 

Kafka does not support ssl using java.security.keystore object.
You can look into SslFactory class at kafka for more information.

share|improve this answer

answered Mar 23 at 4:27

Rohit YadavRohit Yadav

37728

share|improve this answer

answered Mar 23 at 4:27

Rohit YadavRohit Yadav

37728

answered Mar 23 at 4:27

Rohit YadavRohit Yadav

37728

answered Mar 23 at 4:27

Rohit YadavRohit Yadav

37728