Kamil Wdowicz kwdowicz
kwdowicz
/ consumer_async.rs
Created
May 13, 2024 20:34
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| use rdkafka::config::ClientConfig; | |
| use rdkafka::consumer::{Consumer, StreamConsumer, CommitMode}; | |
| use rdkafka::message::{Message, BorrowedMessage}; | |
| use futures::stream::StreamExt; | |
| use tokio; | |
| #[tokio::main] | |
| async fn main() { | |
| let consumer: StreamConsumer = ClientConfig::new() | |
| .set("group.id", "test-group") |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| [dependencies] | |
| chrono = "0.4.38" | |
| fern = "0.6.2" | |
| log = "0.4.21" |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| ***************************************************************** | |
| IDENTIFICATION DIVISION. | |
| PROGRAM-ID. RW1. | |
| AUTHOR. Kamil Wdowicz. | |
| * | |
| * Example on how to read from and write to files. | |
| * | |
| ***************************************************************** | |
| ENVIRONMENT DIVISION. | |
| INPUT-OUTPUT SECTION. |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| //RW1 JOB ,MSGLEVEL=(2,1) | |
| //EXP EXPORT SYMLIST=* | |
| //SETNAME SET MEM=RW1 | |
| //***************************************************/ | |
| //DELETE EXEC PGM=IKJEFT01 | |
| //SYSTSPRT DD SYSOUT=* | |
| //SYSTSIN DD * | |
| DELETE (OUT) | |
| /* | |
| //***************************************************/ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| // generated by quake, do not modify | |
| unbindall | |
| bind TAB "+scores" | |
| bind ENTER "+button2" | |
| bind ESCAPE "togglemenu" | |
| bind SPACE "+moveup" | |
| bind + "sizeup" | |
| bind - "sizedown" | |
| bind / "weapnext" | |
| bind 0 "weapon 10" |
kwdowicz
/ gist:1974703
Created
March 4, 2012 20:40
jeszcze jeden z gaff-a (linode) - z mojego kompa ab sie timeoutuje
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| mamut@li302-202:~$ ab -n 3000 -c 1000 http://btmagic.com:88/ | |
| This is ApacheBench, Version 2.3 <$Revision: 655654 $> | |
| Copyright 1996 Adam Twiss, Zeus Technology Ltd, http://www.zeustech.net/ | |
| Licensed to The Apache Software Foundation, http://www.apache.org/ | |
| Benchmarking btmagic.com (be patient) | |
| Completed 300 requests | |
| Completed 600 requests | |
| Completed 900 requests | |
| Completed 1200 requests |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| ➜ ~ ab -n 3000 -c 1000 http://btmagic.com:88/ | |
| This is ApacheBench, Version 2.3 <$Revision: 655654 $> | |
| Copyright 1996 Adam Twiss, Zeus Technology Ltd, http://www.zeustech.net/ | |
| Licensed to The Apache Software Foundation, http://www.apache.org/ | |
| Benchmarking btmagic.com (be patient) | |
| apr_poll: The timeout specified has expired (70007) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| mamut@li302-202:~$ ab -n 3000 -c 1000 http://btmagic.com:88/ | |
| This is ApacheBench, Version 2.3 <$Revision: 655654 $> | |
| Copyright 1996 Adam Twiss, Zeus Technology Ltd, http://www.zeustech.net/ | |
| Licensed to The Apache Software Foundation, http://www.apache.org/ | |
| Benchmarking btmagic.com (be patient) | |
| Completed 300 requests | |
| Completed 600 requests | |
| Completed 900 requests | |
| Completed 1200 requests |
kwdowicz
/ gist:1517102
Created
December 24, 2011 10:44
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| ## remove old | |
| sed '/vuserbox/d' /etc/hosts > /tmp/hosts | |
| cat /tmp/hosts > /etc/hosts | |
| ## add new | |
| nmap -v -sT 192.168.1.50/24 -p 2222 | grep Discovered | awk '{print $NF"\tvuserbox"}' >> /etc/hosts | |
| ## flush cache | |
| dscacheutil -flushcache |
kwdowicz
/ gist:1435813
Created
December 5, 2011 23:00
Forward any requestes to port 80 to port 3000 (Mac OSX)
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| sudo ipfw add 1 forward 127.0.0.1,3000 ip from any to any 80 in |
NewerOlder