pranaybathini

Produce a record with Kafka headers

echo "{"message":"actual_message"}" | kcat -b localhost:9092 -P -t pranaybathini -H "header1=headervalue"

Consume a record with Kafka headers

kcat -b localhost:9092 \

pranaybathini

Checking Kafka version

docker exec -it 575f9871143c kafka-topics.sh --version

Logging into Bash Shell

docker exec -it 575f9871143c /bin/bash

pranaybathini

version: "2"

services:
  zookeeper:
    image: docker.io/bitnami/zookeeper:latest
    ports:
      - "2181:2181"
    volumes:
      - "zookeeper_data:/bitnami"
    environment:

pranaybathini

version: "3"
services:
  zookeeper:
    image: 'bitnami/zookeeper:latest'
    ports:
      - '2181:2181'
    environment:
      - ALLOW_ANONYMOUS_LOGIN=yes
  kafka:
    image: 'bitnami/kafka:latest'

pranaybathini

class OldTaxSlab{
  
  
      public static double calculateIncomeTax(double income) {
        double ans = 0;

        if (income < 250000) {
            ans += 0;
        } else if (income < 500000) {
            ans += 0.05 * (income - 250000);

pranaybathini

class TrieWithErase {

    private TrieNode root;

    public TrieWithErase() {
        root = new TrieNode();
    }

    public void insert(String word) {
        TrieNode node = root;

pranaybathini

@Repository
public interface UserPostRepository extends JpaRepository<UserPost, UserPostId> {

    //@EmbeddableId key class query
    @Query("SELECT up.userPostId.postId FROM UserPost up where up.userPostId.userId=:userId")
    Set<Integer> getUserPostFromUserId(Integer userId);

}

pranaybathini

import com.pranay.blog.entities.compositekey.UserPostId;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import javax.persistence.*;
import java.io.Serializable;

@Data
@Entity

pranaybathini

import com.pranay.blog.entities.compositekey.UserPostId;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;

import javax.persistence.*;
import java.io.Serializable;

pranaybathini

import lombok.Data;
import lombok.ToString;

import javax.persistence.*;

@Data
@Entity
@ToString
@Table(name = "post")
public class Post {