tomasz
/
code-examples
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: tomasz:ffc7e1a4f2055af320eddea99531990c25d9deb2
Branches Tags
tomasz:master
..
compare: tomasz:a6ea81505c7fb74ad95dafd4b8dba39c6b45a8c8
Branches Tags
tomasz:master

No commits in common. "ffc7e1a4f2055af320eddea99531990c25d9deb2" and "a6ea81505c7fb74ad95dafd4b8dba39c6b45a8c8" have entirely different histories.
ffc7e1a4f2 ... a6ea81505c

2 changed files with 1 additions and 4 deletions
Show Stats Expand all files Collapse all files

4
2024/08/chat_demo1/chat_demo1_web/src/main/java/ch/polgrabia/demos/client/ClientPeriodicStdinScanner.java
View File

@ -34,12 +34,9 @@ public class ClientPeriodicStdinScanner implements Handler<Long> {
@Override @Override
public void handle(Long event) { public void handle(Long event) {
{ {
// TODO this doesn't seem to be working on wsl environment. Needs to be resolved or changed how it
// fetches the input
try { try {
int available = inputStream.available(); int available = inputStream.available();
if (available > 0) { if (available > 0) {
logger.debug("Got available: {}", available);
clientPayloadRemainderBuffer.appendBytes(inputStream.readNBytes(available)); clientPayloadRemainderBuffer.appendBytes(inputStream.readNBytes(available));
} }
@ -59,7 +56,6 @@ public class ClientPeriodicStdinScanner implements Handler<Long> {
Buffer b = Buffer.buffer(len); Buffer b = Buffer.buffer(len);
b = b.appendBytes(clientPayload, prevIdx, len); b = b.appendBytes(clientPayload, prevIdx, len);
b = b.appendByte((byte)'\n'); b = b.appendByte((byte)'\n');
logger.info("Sending binary message: {}", b);;
webSocket.writeBinaryMessage(b); webSocket.writeBinaryMessage(b);
prevIdx = idx + eolLength; prevIdx = idx + eolLength;
} }

1
2024/08/chat_demo1/tools/docker-compose.yaml
View File

@ -9,6 +9,7 @@ services:
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://:9092 KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://:9092
KAFKA_CONTROLLER_LISTENER_NAMES: CONTROLLER KAFKA_CONTROLLER_LISTENER_NAMES: CONTROLLER
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT
KAFKA_CONTROLLER_QUORUM_VOTERS: 1@localhost:9093
KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1 KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1 KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1 KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1