Remove buffer_memory param unsupported in kafka-python 3.x

The buffer_memory producer config was removed in kafka-python 3.0,
causing ValueError on pod startup. Drop the parameter from the
producer init and the corresponding --kafka-buffer-memory CLI argument.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: Rajaditya Chauhan

core/opl/args.py

@@ -171,12 +171,6 @@ def add_kafka_opts(parser):
         default=int(os.getenv("KAFKA_BATCH_SIZE", 16384)),
         help="Max size of the batch before sending (also use env variable KAFKA_BATCH_SIZE)",
     )
-    parser.add_argument(
-        "--kafka-buffer-memory",
-        type=int,
-        default=int(os.getenv("KAFKA_BUFFER_MEMORY", 33554432)),
-        help="Memory the producer can use at max for batching (also use env variable KAFKA_BUFFER_MEMORY)",
-    )
     parser.add_argument(
         "--kafka-retries",
         type=int,

extras/opl/kafka_init.py

@@ -39,7 +39,6 @@ def get_producer(args, status_data=None):
                 "linger_ms": getattr(args, "kafka_linger_ms", 0),
                 "compression_type": getattr(args, "kafka_compression_type", None),
                 "batch_size": getattr(args, "kafka_batch_size", 16384),
-                "buffer_memory": getattr(args, "kafka_buffer_memory", 33554432),
                 "retries": getattr(args, "kafka_retries", 0),
             }