Test against java kafka client

[crepererum]

We currently have a test matrix that produces and consumes data using rdkafka and rskafka in all supported compression formats:

rskafka/tests/produce_consume.rs

Lines 16 to 106 in 0f9cd4e

	#[tokio::test]
	async fn test_produce_rdkafka_consume_rdkafka_nocompression() {
	assert_produce_consume(produce_rdkafka, consume_rdkafka, Compression::NoCompression).await;
	}
	#[tokio::test]
	async fn test_produce_rskafka_consume_rdkafka_nocompression() {
	assert_produce_consume(produce_rskafka, consume_rdkafka, Compression::NoCompression).await;
	}
	#[tokio::test]
	async fn test_produce_rdkafka_consume_rskafka_nocompression() {
	assert_produce_consume(produce_rdkafka, consume_rskafka, Compression::NoCompression).await;
	}
	#[tokio::test]
	async fn test_produce_rskafka_consume_rskafka_nocompression() {
	assert_produce_consume(produce_rskafka, consume_rskafka, Compression::NoCompression).await;
	}
	#[cfg(feature = "compression-gzip")]
	#[tokio::test]
	async fn test_produce_rdkafka_consume_rdkafka_gzip() {
	assert_produce_consume(produce_rdkafka, consume_rdkafka, Compression::Gzip).await;
	}
	#[cfg(feature = "compression-gzip")]
	#[tokio::test]
	async fn test_produce_rskafka_consume_rdkafka_gzip() {
	assert_produce_consume(produce_rskafka, consume_rdkafka, Compression::Gzip).await;
	}
	#[cfg(feature = "compression-gzip")]
	#[tokio::test]
	async fn test_produce_rdkafka_consume_rskafka_gzip() {
	assert_produce_consume(produce_rdkafka, consume_rskafka, Compression::Gzip).await;
	}
	#[cfg(feature = "compression-gzip")]
	#[tokio::test]
	async fn test_produce_rskafka_consume_rskafka_gzip() {
	assert_produce_consume(produce_rskafka, consume_rskafka, Compression::Gzip).await;
	}
	#[cfg(feature = "compression-lz4")]
	#[tokio::test]
	async fn test_produce_rdkafka_consume_rdkafka_lz4() {
	assert_produce_consume(produce_rdkafka, consume_rdkafka, Compression::Lz4).await;
	}
	#[cfg(feature = "compression-lz4")]
	#[tokio::test]
	async fn test_produce_rskafka_consume_rdkafka_lz4() {
	assert_produce_consume(produce_rskafka, consume_rdkafka, Compression::Lz4).await;
	}
	#[cfg(feature = "compression-lz4")]
	#[tokio::test]
	async fn test_produce_rdkafka_consume_rskafka_lz4() {
	assert_produce_consume(produce_rdkafka, consume_rskafka, Compression::Lz4).await;
	}
	#[cfg(feature = "compression-lz4")]
	#[tokio::test]
	async fn test_produce_rskafka_consume_rskafka_lz4() {
	assert_produce_consume(produce_rskafka, consume_rskafka, Compression::Lz4).await;
	}
	#[cfg(feature = "compression-snappy")]
	#[tokio::test]
	async fn test_produce_rdkafka_consume_rdkafka_snappy() {
	assert_produce_consume(produce_rdkafka, consume_rdkafka, Compression::Snappy).await;
	}
	#[cfg(feature = "compression-snappy")]
	#[tokio::test]
	async fn test_produce_rskafka_consume_rdkafka_snappy() {
	assert_produce_consume(produce_rskafka, consume_rdkafka, Compression::Snappy).await;
	}
	#[cfg(feature = "compression-snappy")]
	#[tokio::test]
	async fn test_produce_rdkafka_consume_rskafka_snappy() {
	assert_produce_consume(produce_rdkafka, consume_rskafka, Compression::Snappy).await;
	}
	#[cfg(feature = "compression-snappy")]
	#[tokio::test]
	async fn test_produce_rskafka_consume_rskafka_snappy() {
	assert_produce_consume(produce_rskafka, consume_rskafka, Compression::Snappy).await;
	}

Since record batches are mostly only processed by the clients, it would be nice to add an official java/scala client to test matrix via some bridge / CLI call, just to make sure we can work with most of the ecosystem.