kirshiyin89

import demo.entities.ServerRecord;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.persistence.EntityManager;
import javax.persistence.Tuple;
import javax.persistence.TupleElement;
import javax.persistence.TypedQuery;
import javax.persistence.criteria.CriteriaBuilder;

kirshiyin89

import 'dart:async';
import 'package:http/http.dart' as http;
import 'dart:convert' as convert;

class BackendService {
  static Future<List<Map<String, String>>> getSuggestions(String query) async {
    if (query.isEmpty && query.length < 3) {
      print('Query needs to be at least 3 chars');
      return Future.value([]);
    }

kirshiyin89

import 'package:flutter/material.dart';
import 'package:flutter_typeahead/flutter_typeahead.dart';
import 'data.dart';

class MyMaterialApp extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Flutter Datamuse Autocomplete Demo',
      home: MyHomePage(),

kirshiyin89

import pandas as pd
import itertools
import pinecone
from sentence_transformers import SentenceTransformer

api_key = "YOUR API KEY FROM PINECONE CONSOLE"
pinecone.init(api_key=api_key, environment='us-west1-gcp')

index_name = "question-answering"

kirshiyin89

    public static int generateNumberFromRange(int maxRange) throws NoSuchAlgorithmException {
        Random rand = SecureRandom.getInstanceStrong();
        int randomNum;
        if (maxRange == 100) {
            randomNum = rand.nextInt(maxRange / 2) * 2;
        } else {
            randomNum = rand.nextInt(maxRange / 2) * 2 + 1;
        }
        return randomNum;
    }

kirshiyin89

@SpringBootApplication
public class KafkaErrorHandlingApplication {

    public static void main(String[] args) {
        SpringApplication.run(KafkaErrorHandlingApplication.class, args);
    }

}

kirshiyin89

@RestController
@RequiredArgsConstructor
@Slf4j
public class ProducerController {

    private final KafkaTemplate<String, String> kafkaTemplate;

    @Value("${topic}")
    private String topic;

kirshiyin89

@Component
@Slf4j
public class MyKafkaListener {

    @RetryableTopic(
            attempts = "5",
            topicSuffixingStrategy = TopicSuffixingStrategy.SUFFIX_WITH_INDEX_VALUE,
            backoff = @Backoff(delay = 1000, multiplier = 2.0),
            exclude = {SerializationException.class, DeserializationException.class}

kirshiyin89

topic: my-topic

server:
  port: 8090
spring:
  kafka:
    bootstrap-servers: http://localhost:29092
    properties:
      spring.deserializer.value.delegate.class: org.springframework.kafka.support.serializer.JsonDeserializer
      security.protocol: PLAINTEXT

kirshiyin89

version: '2.1'
networks:
  app-tier:
    driver: bridge
services:

  zookeeper:
    image: confluentinc/cp-zookeeper:latest
    environment:
      ZOOKEEPER_CLIENT_PORT: 2181