fix: Kafka streaming flag compatibility and improve examples

- Fixed command flag format issues in CLI module (-content instead of --content-type)
- Fixed Kafka-related flag names to match Go binary expectations
- Added native_kafka_demo.py and safe_kafka_demo.py example scripts
- Updated the stream_to_kafka function for better error handling
- Fixed session ID parameter handling across API
- Improved documentation with usage examples
- Updated CHANGELOG.md for version 0.3.1

This commit addresses critical issues in the Kafka streaming functionality,
ensuring compatibility between the Python wrapper and the Go binary. The
added examples demonstrate both basic and type-safe usage patterns.

Author: justrach

.DS_Store

@@ -2,7 +2,23 @@
 
 All notable changes to Pathik will be documented in this file.
 
-## [0.3.0] - 2023-10-27
+## [0.3.1] - 2023-10-28
+
+### Added
+- New example scripts for Kafka streaming: `native_kafka_demo.py` and `safe_kafka_demo.py`
+- Improved documentation for Kafka integration
+
+### Changed
+- Fixed command line flags to match Go binary expectations (-content instead of --content-type)
+- Correct ordering of arguments for Kafka flags
+- Simplified Kafka streaming interface in __init__.py
+
+### Fixed
+- Fixed binary command flag format issues in CLI module
+- Resolved argument mismatch between Python wrapper and Go binary
+- Fixed session ID handling in Kafka streaming functions
+
+## [0.3.0] - 2023-10-28
 
 ### Added
 - Enhanced URL validation to prevent security vulnerabilities
@@ -11,25 +27,21 @@ All notable changes to Pathik will be documented in this file.
 - New `kafka_consumer_direct.py` script with better security
 - Configurable compression options (Gzip and Snappy support)
 - Added Snappy compression library installation instructions
-- New example scripts for Kafka streaming: `native_kafka_demo.py` and `safe_kafka_demo.py`
 
 ### Changed
 - Updated Kafka producer to use Gzip compression instead of Snappy by default
 - Improved input validation across all user-provided parameters
 - Enhanced session ID tracking for better multi-user support
 - Refactored code for better security and performance
-- Fixed command line flags to match Go binary expectations (-content instead of --content-type)
-- Correct ordering of arguments for Kafka flags
 
 ### Fixed
 - Fixed URL validation to properly handle invalid URLs
 - Fixed command execution when arguments are missing
 - Fixed UnsupportedCodecError by adding proper compression library support
 - Resolved buffer size issues when streaming large web pages
 - Fixed message encoding problems in Kafka consumer
-- Fixed binary command flag format issues in CLI module
 
-## [0.2.6] - 2023-10-26
+## [0.2.6] - 2025-03-27
 
 ### Added
 - Kafka streaming functionality

CHANGELOG.md

@@ -14,7 +14,7 @@
 import shutil
 
 # Set version
-__version__ = "0.3.0"  # Incremented version for command ordering fix
+__version__ = "0.3.1"  # Incremented version for command ordering fix
 
 # NOTE: Version 0.3.32 fixes a critical bug with command-line argument ordering.
 # Previously, flags were incorrectly placed after URLs, causing errors like: