Member since
02-07-2023
4
Posts
0
Kudos Received
0
Solutions
09-28-2023
02:05 AM
I am following https://medium.com/egen/how-to-configure-oauth2-authentication-for-apache-kafka-cluster-using-okta-8c60d4a85b43 for setting up OAuth2.0 But when I try to produce data I get Error while fetching metadata with correlation id 43 : {myTopic=TOPIC_AUTHORIZATION_FAILED}. Can anyone please help me out I tried adding invalid details in my sasl-oauth2-consumerapp-config.properties file to check if it is picking the right file , it seems like right file is picked.
... View more
Labels:
- Labels:
-
Apache Kafka
04-17-2023
09:24 PM
Hi, I want to convert the data from JSON to Avro using the ConvertRecord processor. This is my flow and the error I am getting: I have a docker image for the confluent schema registry. The curl for registering the schema in the schema registry is : curl --location --request GET 'http://localhost:8085/schemas/ids/42' \ --header 'Content-Type: application/vnd.schemaregistry.v1+json' \ --data '{"schema": "{\"type\":\"record\",\"name\":\"User\",\"fields\":[{\"name\":\"id\",\"type\":\"int\"},{\"name\":\"username\",\"type\":\"string\"},{\"name\":\"email\",\"type\":\"string\"}]}"}' Generate flow file configurations: convertRecord Configurations: AvroRecordSetWriter configurations: JsonTreeReader configurations: Confluent Schema Registry :
... View more
Labels:
- Labels:
-
Apache NiFi
03-05-2023
06:59 PM
Yupp..That solved the problem .Thanks
... View more
03-03-2023
02:43 AM
I want to access the reporting task id of a particular reporting task. For doing the same , I thought about fetching all reporting task id and then searching for a particular one. Is there any nifi-api that can give me all the reporting task ids or any other approach to solve this problem.
... View more
Labels:
- Labels:
-
Apache NiFi