Skip to content

Instantly share code, notes, and snippets.

Avatar
🏠
Working from home

Neenad Ingole ninadingole

🏠
Working from home
View GitHub Profile
View codeql-config.yml
name: "My CodeQL config"
disable-default-queries: true
languages: java
queries:
- name: Extended Security
uses: security-extended
- name: Security and Quality
View codeql-analysis.yml
name: "CodeQL"
on:
push:
branches: [master, ]
pull_request:
# The branches below must be a subset of the branches above
branches: [master]
# schedule:
# - cron: '0 3 * * 4'
View keybase.md

Keybase proof

I hereby claim:

  • I am ninadingole on github.
  • I am iamninad (https://keybase.io/iamninad) on keybase.
  • I have a public key ASDQ_lKHv4aZIwHqiD5wWJOCHV4euhaPoJGdYPa3Anq_hwo

To claim this, I am signing this object:

View cloudSettings
{"lastUpload":"2020-05-06T12:15:46.434Z","extensionVersion":"v3.4.3"}
View movie_handler.go
package internal
import (
"context"
"encoding/json"
"errors"
"fmt"
"log"
"net/http"
"os"
@ninadingole
ninadingole / sbt.scala
Last active Mar 17, 2019
Organising Scala Tests In SBT
View sbt.scala
#########################################
#### Inside project/E2E.class object ####
#########################################
import sbt.{Configuration, Defaults, Test, inConfig}
import sbt._
import sbt.Keys._
object E2E {
final val E2ETest = Configuration.of("EndToEndTest", "e2e") extend (Test)
View rkafka.prm
REPLICAT rkafka
TARGETDB LIBFILE libggjava.so SET property=dirprm/rkafka_handler.props
REPORTCOUNT EVERY 1 MINUTES, RATE
GROUPTRANSOPS 1000
MAP *.*.*, TARGET *.*.*;
View rkafka_handler.props
gg.handlerlist=kafkaconnect
#The handler properties
gg.handler.kafkaconnect.type=kafkaconnect
gg.handler.kafkaconnect.kafkaProducerConfigFile=kafkaconnect.properties
# See http://docs.oracle.com/goldengate/bd123110/gg-bd/GADBD/using-kafka-connect-handler.htm#GUID-A87CAFFA-DACF-43A0-8C6C-5C64B578D606
gg.handler.kafkaconnect.topicMappingTemplate=ora-ogg-${schemaName}-${tableName}-avro
gg.handler.kafkaconnect.keyMappingTemplate=${primaryKeys}
View kafkaconnect.properties
bootstrap.servers=localhost:9092
key.converter=io.confluent.connect.avro.AvroConverter
value.converter=io.confluent.connect.avro.AvroConverter
key.converter.schema.registry.url=http://localhost:8081
value.converter.schema.registry.url=http://localhost:8081
#value.converter=org.apache.kafka.connect.json.JsonConverter
#key.converter=org.apache.kafka.connect.json.JsonConverter
#key.converter.schemas.enable=false
#value.converter.schemas.enable=false
View event_processor.scala
def buildEventStream = {
import AppSerdes.movieBEventSerde.eventConsumed
builder.stream[Int, BusinessEvent]("events")
}
private val eventStreams: KStreamS[Int, BusinessEvent] = buildEventStream
def filterEventsByType(eventType: String): KStreamS[Int, BusinessEvent] = {
eventStreams.filter((_: Int, event: BusinessEvent) => event.eventType.equalsIgnoreCase(eventType))
}
You can’t perform that action at this time.