rkpattnaik780

import time
import requests

def _get_token(config):
    payload = {"grant_type": "client_credentials", "scope": "api.iam.service_accounts"}
    resp = requests.post(
        RHOAS_SERVICE_ACCOUNT_OAUTH_TOKEN_URL,
        auth=(
            RHOAS_SERVICE_ACCOUNT_CLIENT_ID,
            RHOAS_SERVICE_ACCOUNT_CLIENT_SECRET,

rkpattnaik780

import java.util.Arrays;

import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import java.time.Duration;

public class ConsumerExample {

rkpattnaik780

package org.acme.kafka;

import javax.enterprise.context.ApplicationScoped;

import org.eclipse.microprofile.reactive.messaging.Acknowledgment;
import org.eclipse.microprofile.reactive.messaging.Incoming;
import org.eclipse.microprofile.reactive.messaging.Outgoing;

import io.smallrye.reactive.messaging.annotations.Broadcast;

rkpattnaik780

import java.util.HashMap;
import java.util.Map;

public class KafkaConfig {

    static Map<String, Object> config() {

        Map<String, Object> config = new HashMap<>();

        config.put("bootstrap.servers", KAFKA_HOST);