I have a topic with values of 100 rows and all are committed. I want to fetch the value and key of offset '50' (say) and update the value of that particular offset and push back the change. Please kindly suggest all possible ways to overcome this scenario.
is it possible to fetch and update committed values in offset from kafka topic using mule 4
91 views Asked by soumya At
0
There are 0 answers
Related Questions in KAFKA-CONSUMER-API
- Data Reading From Kafka
- realtime consume data from kafka to clickhouse
- How to resolve KafkaConnectionError: Socket EVENT_READ without in-flight-requests
- Latest Stable offset in Kafka
- Switch between Kafka topics
- Consuming messages from Kafka topic one by one takes too long time. How can I shorten this time? Is reading multiple messages at one time possible?
- Testing Kafka Producer and Consumer
- Docker-compose: ModuleNotFoundError: No module named 'core'
- Problem with kafka request v3+ serealization. Broker cant deserialize message
- Kafka message not being consumed and offset not committed
- Empty consumer groups are not getting removed from kafka
- Detecting new partitions in a kafka topic
- App info kafka.consumer for group-id unregistered
- How to wrap @KafkaListener for custom method arguments?
- Kafka-Spark Streaming Distributed The group coordinate is not available (Host2:9092(id:2147483645))
Related Questions in MULESOFT
- I need a mulesoft real time project
- How to compare two dates with only month and year in mule
- remove object from complex object if specific value is null
- How can I effectively manage SFTP Private key files in MuleSoft applications
- Get flow name from subflow
- Convert a single column values into multiple rows using dataweave
- How to dynamically convert an list of strings into key value pair using dataweave 2.0
- Using $ in a string in a dataweave expression
- Using Maven to build an Java SDK Mulesoft plugin snapshot
- Creating custom rule for API Governance - How to check for traits?
- Generating an Array based on a total Count and split Number
- Mulesoft Dataweave use a map to update an object or use the update function or update operator
- Mule 4 why is the playground result different than a transform component
- What should be my response body in raml if i am sending hashmap as response?
- Sockets Connector - is there any way to read data instead of send and receive - Mule 4
Related Questions in MULE4
- How to compare two dates with only month and year in mule
- How can I effectively manage SFTP Private key files in MuleSoft applications
- Get flow name from subflow
- Convert a single column values into multiple rows using dataweave
- How to dynamically convert an list of strings into key value pair using dataweave 2.0
- Using $ in a string in a dataweave expression
- Using Maven to build an Java SDK Mulesoft plugin snapshot
- Generating an Array based on a total Count and split Number
- Mulesoft Dataweave use a map to update an object or use the update function or update operator
- Mule 4 why is the playground result different than a transform component
- What should be my response body in raml if i am sending hashmap as response?
- How do I transform the incoming JSON payload having objects to a payload having a list of the objects expected by the downstream system
- Import Java Jar in Mulesoft Project
- How to query Bigquery table using Query operator
- Mule4 JWT connection to BigQuery fails during build
Related Questions in MULE-CONNECTOR
- Sockets Connector - is there any way to read data instead of send and receive - Mule 4
- Get Object from specific Bucket on AWS S3 in Mule 4
- Accessing MuleSoft Anypoint Exchange Properties
- Error Parsing json message through Kafka listener in Mulesoft
- Mule Salesforce connection starts failing with INVALID_SESSION_ID
- Mule 4- Salesforce connector Basic Auth connection failed
- Mule Configuration Flow SAXParseException
- Mule 4 Getting Database Connection in Java Code
- Mulesoft Connector for Azure Service bus returns sessionId as null
- Database connector's Insert operation for inserting Datetime type issue
- Mule 4 database connector taking more time to execute a stored procedure
- password credentials grant type usage in HTTP Requestor of Mulesoft
- Create DataSet in Salesforce Analytics using Mule
- Mule 4 stored procedure XMLType parameter
- How to move a file in a folder with timestamp in mule 4
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
Popular Tags
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)