<commit_before>quarkus.http.port=8081

kafka.bootstrap.servers=localhost:9092
mp.messaging.incoming.orders.connector=smallrye-kafka
mp.messaging.incoming.orders.topic=dbserver1.inventory.purchaseorder
mp.messaging.incoming.orders.bootstrap.servers=${kafka.bootstrap.servers}
mp.messaging.incoming.orders.group.id=cache-update-service
mp.messaging.incoming.orders.key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
mp.messaging.incoming.orders.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer

mp.messaging.incoming.orderlines.connector=smallrye-kafka
mp.messaging.incoming.orderlines.topic=dbserver1.inventory.orderline
mp.messaging.incoming.orderlines.bootstrap.servers=${kafka.bootstrap.servers}
mp.messaging.incoming.orderlines.group.id=cache-update-service
mp.messaging.incoming.orderlines.key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
mp.messaging.incoming.orderlines.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer

mp.messaging.incoming.orderwithlines.connector=smallrye-kafka
mp.messaging.incoming.orderwithlines.topic=orders-with-lines
mp.messaging.incoming.orderwithlines.bootstrap.servers=${kafka.bootstrap.servers}
mp.messaging.incoming.orderwithlines.group.id=cache-update-service
mp.messaging.incoming.orderwithlines.key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
mp.messaging.incoming.orderwithlines.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer

orders.topic=dbserver1.inventory.purchaseorder
order.lines.topic=dbserver1.inventory.orderline
orders.with.lines.topic=orders-with-lines

quarkus.kafka-streams.bootstrap-servers=${kafka.bootstrap.servers}
quarkus.kafka-streams.application-id=order-joiner1
quarkus.kafka-streams.application-server=${hostname}:8080
quarkus.kafka-streams.topics=${orders.topic},${order.lines.topic}

# streams options
kafka-streams.cache.max.bytes.buffering=10240
kafka-streams.commit.interval.ms=1000
kafka-streams.metadata.max.age.ms=500
# kafka-streams.auto.offset.reset=earliest
kafka-streams.auto.offset.reset=latest
kafka-streams.metrics.recording.level=DEBUG
# kafka-streams.consumer.session.timeout.ms=150
# kafka-streams.consumer.heartbeat.interval.ms=100

# Infinispan
quarkus.infinispan-client.server-list=localhost:41222
quarkus.infinispan-client.client-intelligence=BASIC<commit_msg>[infinispan] Less latency for Kafka Streams<commit_after>quarkus.http.port=8081

kafka.bootstrap.servers=localhost:9092
mp.messaging.incoming.orders.connector=smallrye-kafka
mp.messaging.incoming.orders.topic=dbserver1.inventory.purchaseorder
mp.messaging.incoming.orders.bootstrap.servers=${kafka.bootstrap.servers}
mp.messaging.incoming.orders.group.id=cache-update-service
mp.messaging.incoming.orders.key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
mp.messaging.incoming.orders.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer

mp.messaging.incoming.orderlines.connector=smallrye-kafka
mp.messaging.incoming.orderlines.topic=dbserver1.inventory.orderline
mp.messaging.incoming.orderlines.bootstrap.servers=${kafka.bootstrap.servers}
mp.messaging.incoming.orderlines.group.id=cache-update-service
mp.messaging.incoming.orderlines.key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
mp.messaging.incoming.orderlines.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer

mp.messaging.incoming.orderwithlines.connector=smallrye-kafka
mp.messaging.incoming.orderwithlines.topic=orders-with-lines
mp.messaging.incoming.orderwithlines.bootstrap.servers=${kafka.bootstrap.servers}
mp.messaging.incoming.orderwithlines.group.id=cache-update-service
mp.messaging.incoming.orderwithlines.key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
mp.messaging.incoming.orderwithlines.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer

orders.topic=dbserver1.inventory.purchaseorder
order.lines.topic=dbserver1.inventory.orderline
orders.with.lines.topic=orders-with-lines

quarkus.kafka-streams.bootstrap-servers=${kafka.bootstrap.servers}
quarkus.kafka-streams.application-id=order-joiner1
quarkus.kafka-streams.application-server=${hostname}:8080
quarkus.kafka-streams.topics=${orders.topic},${order.lines.topic}

# streams options
kafka-streams.cache.max.bytes.buffering=10240
kafka-streams.commit.interval.ms=100
kafka-streams.consumer.fetch.max.wait.ms=100
kafka-streams.metadata.max.age.ms=500
# kafka-streams.auto.offset.reset=earliest
kafka-streams.auto.offset.reset=latest
kafka-streams.metrics.recording.level=DEBUG
# kafka-streams.consumer.session.timeout.ms=150
# kafka-streams.consumer.heartbeat.interval.ms=100

# Infinispan
quarkus.infinispan-client.server-list=localhost:41222
quarkus.infinispan-client.client-intelligence=BASIC
{'fraction_non_alphanumeric': 0.11910619106191062, 'fraction_numerical': 0.016810168101681018, 'mean_word_length': 7.9195612431444244, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '7253379', 'n_tokens_mistral': 1732, 'n_tokens_neox': 1640, 'n_words': 85}