@dan No worries. I got your email and have submitted a support ticket. Thanks for the quick replies!

@robotdan Thanks. BTW, I notice that FusionAuth Cloud is at 1.22.2. When does 1.24.0 hit production? We're using the cloud version.

@robotdan

That's great! Thanks for tracking that one down.

I'll be on the lookout for the fix.

BTW, I started using that sasl.jaas.config param since my local client is Java and I was playing around with things (adding properties) trying to get it to work in FusionAuth.

But is there any other way that other clients would typically specify credentials for Kafka (specifically in your UI)? Just curious how others are doing it.

Thanks.

@robotdan

I'm using Java 11. I didn't have to add anything to the keystore.

The thing is, I can go into Integrations and enable Kafka and paste the following into the Producer configuration (leaving the topic as "fusion"), and it will tell me "Successfully sent a test message":

bootstrap.servers=junk
sasl.jass.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="xxxxx" password="xxxxx"
max.block.ms=5000
request.timeout.ms=2000

Those settings aren't even valid, but it still gives me a success message.

Can you reproduce that?

Thanks.

@dan Hi Dan,

We're actually using FusionAuth in the Cloud. We're not running locally.

Thanks.

Hi,

I'm trying to set up an integration with Kafka, and I finally got it to say that it was able to send a test message successfully, but I never see the message in my broker, nor does my consumer receive it.

First, I added my bootstrap.servers property, and then I was getting timeouts: org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata

I was finally able to get it to say that it was successful by adding the sasl.jass.config property, which contains credentials, like:

sasl.jass.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="XXXXXXXX" password="XXXXXXXX"

However, oddly enough, it doesn't seem to care what the credentials are set to. Also, if I comment out this line (prefix with #), it still seems to work. It's only when I remove that line that it gives me the Timeout exception.

Also, it doesn't seem to care what the Topic name is.

BTW, I have a Java Producer and Consumer example working fine that uses these same properties.

Also, I'm using a free account on cloudkarafka.com if that helps.

But without any logging available, I can't tell what's really going on.

Can you help or give any advice?

Thanks.

@dan No worries. I got your email and have submitted a support ticket. Thanks for the quick replies!

@dan I can view that link, but it just says "You may find all of the community resources available to you on our community page."

How do we do this? We have a Deployment with the High-Availability plan, Community Edition. I don't see any means to submit a support ticket. The HA plan says that it supports custom domain.