fixes to improve stability of the ci build (#14752)

Author: alexsku

docker/broker/env/docker.env

@@ -4,7 +4,7 @@ KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEX
 KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://broker:29092,PLAINTEXT_HOST://localhost:9092
 KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1
 KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS=0
-KAFKA_HEAP_OPTS=-Xms256m -Xmx256m
+KAFKA_HEAP_OPTS=-Xms512m -Xmx512m
 KAFKA_CONFLUENT_SUPPORT_METRICS_ENABLE=false
 KAFKA_MESSAGE_MAX_BYTES=5242880
 KAFKA_MAX_MESSAGE_BYTES=5242880

docker/quickstart/docker-compose.quickstart-profile.yml

@@ -170,7 +170,7 @@ services:
       KAFKA_CONTROLLER_LISTENER_NAMES: CONTROLLER
       KAFKA_CONTROLLER_QUORUM_VOTERS: 1@broker:39092
       KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: '0'
-      KAFKA_HEAP_OPTS: -Xms256m -Xmx256m
+      KAFKA_HEAP_OPTS: -Xms512m -Xmx512m
       KAFKA_INTER_BROKER_LISTENER_NAME: BROKER
       KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: CONTROLLER:PLAINTEXT,BROKER:PLAINTEXT,EXTERNAL:PLAINTEXT
       KAFKA_LISTENERS: BROKER://broker:29092,EXTERNAL://broker:9092,CONTROLLER://broker:39092

docker/quickstart/docker-compose.quickstart.yml

@@ -13,7 +13,7 @@ services:
     - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://broker:29092,PLAINTEXT_HOST://localhost:9092
     - KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1
     - KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS=0
-    - KAFKA_HEAP_OPTS=-Xms256m -Xmx256m
+    - KAFKA_HEAP_OPTS=-Xms512m -Xmx512m
     - KAFKA_CONFLUENT_SUPPORT_METRICS_ENABLE=false
     - KAFKA_MESSAGE_MAX_BYTES=5242880
     - KAFKA_MAX_MESSAGE_BYTES=5242880

smoke-test/tests/consistency_utils.py

@@ -5,7 +5,7 @@
 
 USE_STATIC_SLEEP: bool = bool(os.getenv("USE_STATIC_SLEEP", False))
 ELASTICSEARCH_REFRESH_INTERVAL_SECONDS: int = int(
-    os.getenv("ELASTICSEARCH_REFRESH_INTERVAL_SECONDS", 1)
+    os.getenv("ELASTICSEARCH_REFRESH_INTERVAL_SECONDS", 3)
 )
 KAFKA_BOOTSTRAP_SERVER: str = str(os.getenv("KAFKA_BOOTSTRAP_SERVER", "broker:29092"))
 

smoke-test/tests/trace/test_api_trace.py

@@ -440,7 +440,7 @@ def extract_trace_system_metadata(system_metadata):
     return system_metadata["properties"]["telemetryTraceId"]
 
 
-def delete_elasticsearch_trace(trace_id, timeout=10, refresh_interval=1):
+def delete_elasticsearch_trace(trace_id, timeout=10, refresh_interval=3):
     field_name = "telemetryTraceId"
     index_name = "system_metadata_service_v1"