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);

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.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

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

KAFKA_HOST=
RHOAS_SERVICE_ACCOUNT_CLIENT_ID=
RHOAS_SERVICE_ACCOUNT_CLIENT_SECRET=

rkpattnaik780

{
    "swagger":"2.0",
    "info":{
        "description":"This is a sample server Petstore server via JSON.",
        "version":"1.0.0",
        "title":"Swagger Petstore (JSON)",
        "termsOfService":"http://helloreverb.com/terms/",
        "contact":{
            "email":"apiteam@wordnik.com"
        },

rkpattnaik780

{
  "type" : "record",
  "name" : "Tweet",
  "fields" : [ 
   {
      "name" : "user",
      "type" : "string"
   }, 
   {
      "name" : "text",

rkpattnaik780

// GetCurrent_Context returns the name of the currently selected context
func GetCurrent_Context(svcContext *servicecontext.Context, localizer localize.Localizer) (*servicecontext.ServiceConfig, error) {

	if svcContext.CurrentContext == "" {
		return nil, localizer.MustLocalizeError("context.common.error.notSet")
	}

	currCtx, ok := svcContext.Contexts[svcContext.CurrentContext]
	if !ok {
		return nil, localizer.MustLocalizeError("context.common.error.context.notFound", localize.NewEntry("Name", svcContext.CurrentContext))

rkpattnaik780

const template = document.createElement('template');

template.innerHTML = `
  <div>
    Hello Weather App
  </div>
`

class WeatherCard extends HTMLElement {
  constructor() {

rkpattnaik780

<template>
  <div class="hello">
    <a href="http://localhost:3000/auth/github">
      <button>Sign-In With Github</button>
    </a>
  </div>
</template>

<script>
import axios from "axios";