pradeek p mohandas pradeekpmohandas

#ppm

pradeekpmohandas / temp

Created February 27, 2023 08:15

	<source>
	@type tail
	format json
	path /var/log/jenkins/jenkins.log
	pos_file /var/lib/google-fluentd/pos/jenkins-log.pos
	tag jenkins-log
	read_from_head true
	</source>

	<match jenkins-log>

pradeekpmohandas / Consumer-kafka-errohandling.java

Created August 1, 2020 20:15

	@KafkaHandler
	public void consume(@Payload String input,@Header(KafkaHeaders.OFFSET) String offset){
	log.info(" offset: " + offset + "Incoming info: "+student);
	try {
	ObjectMapper mapper = new ObjectMapper();
	Student student = mapper.readValue(input, Student.class);
	log.info("Student :"+json);
	} catch (JsonProcessingException e) {
	e.printStackTrace();
	log.error(e.getMessage());

pradeekpmohandas / Consumer-kafka.java

Last active August 1, 2020 18:12

	@Log4j2
	@Service
	@KafkaListener(id = "temp-id",topics = "#{'${spring.kafka.incoming.topic}'.split(',')}")
	public class Consumer {

	@KafkaHandler
	public void consume(Student student,@Header(KafkaHeaders.OFFSET) String offset)
	log.info("offset:" + offset + "Incoming info: "+student);
	}
	}

pradeekpmohandas / Producer-Kafka.java

Created August 1, 2020 17:38

	@Configuration
	public class Producer {

	@Autowired
	private KafkaTemplate<String, Student> kafkaTemplate;

	public String pushIntoKafka(String topic, Student student) {
	try {
	kafkaTemplate.send(topic, student);
	return "success";

pradeekpmohandas / Producer-Kafka.java

Created August 1, 2020 17:38

	@Configuration
	public class Producer {

	@Autowired
	private KafkaTemplate<String, Student> kafkaTemplate;

	public String pushIntoKafka(String topic, Student student) {
	try {
	kafkaTemplate.send(topic, student);
	return "success";

pradeekpmohandas / snakecoin.py

Created February 22, 2018 05:46 — forked from aunyks/snakecoin.py

	import hashlib as hasher
	import datetime as date

	# Define what a Snakecoin block is
	class Block:
	def __init__(self, index, timestamp, data, previous_hash):
	self.index = index
	self.timestamp = timestamp
	self.data = data
	self.previous_hash = previous_hash