echo "{"message":"actual_message"}" | kcat -b localhost:9092 -P -t pranaybathini -H "header1=headervalue"
kcat -b localhost:9092 \
version: "2" | |
services: | |
zookeeper: | |
image: docker.io/bitnami/zookeeper:latest | |
ports: | |
- "2181:2181" | |
volumes: | |
- "zookeeper_data:/bitnami" | |
environment: |
version: "3" | |
services: | |
zookeeper: | |
image: 'bitnami/zookeeper:latest' | |
ports: | |
- '2181:2181' | |
environment: | |
- ALLOW_ANONYMOUS_LOGIN=yes | |
kafka: | |
image: 'bitnami/kafka:latest' |
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); |
class TrieWithErase { | |
private TrieNode root; | |
public TrieWithErase() { | |
root = new TrieNode(); | |
} | |
public void insert(String word) { | |
TrieNode node = root; |
@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); | |
} |
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 |
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; |
import lombok.Data; | |
import lombok.ToString; | |
import javax.persistence.*; | |
@Data | |
@Entity | |
@ToString | |
@Table(name = "post") | |
public class Post { |