modified kafka test cases to match datacontenttype
Signed-off-by: vivjd <vivjdeng@hotmail.com>
This commit is contained in:
parent
06f09b0955
commit
7430e9e080
|
@ -59,7 +59,7 @@ class KafkaConversionTestBase:
|
|||
"source": "pytest",
|
||||
"type": "com.pytest.test",
|
||||
"time": datetime.datetime(2000, 1, 1, 6, 42, 33).isoformat(),
|
||||
"content-type": "foo",
|
||||
"datacontenttype": "foo",
|
||||
"partitionkey": "test_key_123",
|
||||
},
|
||||
data=self.expected_data,
|
||||
|
|
Loading…
Reference in New Issue